11246:: Addressing the latest review comments

Author: vimanikag

core/src/main/java/io/grpc/internal/ServerCallImpl.java

@@ -331,7 +331,7 @@ private void messagesAvailableInternal(final MessageProducer producer) {
         InputStream message;
         while ((message = producer.next()) != null) {
           ReqT parsedMessage;
-          try {
+          try (InputStream ignored = message) {
             parsedMessage = call.method.parseRequest(message);
           } catch (StatusRuntimeException e) {
             GrpcUtil.closeQuietly(message);
@@ -340,13 +340,7 @@ private void messagesAvailableInternal(final MessageProducer producer) {
             call.close(e.getStatus(), new Metadata());
             return;
           }
-          try {
-            listener.onMessage(parsedMessage);
-          } catch (Throwable t) {
-            GrpcUtil.closeQuietly(message);
-            message.close();
-            throw t;
-          }
+          listener.onMessage(parsedMessage);
         }
       } catch (Throwable t) {
         GrpcUtil.closeQuietly(producer);

core/src/test/java/io/grpc/internal/ServerCallImplTest.java

@@ -531,7 +531,6 @@ public Long parse(InputStream stream) {
 
     streamListener.halfClosed();
     verify(callListener, never()).onHalfClose();
-    verify(message).close();
     verify(callListener,never()).onMessage(any());
   }