WIP

Author: panchenko

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

@@ -972,6 +972,7 @@ public static boolean getFlag(String envVarName, boolean enableByDefault) {
     }
   }
 
+
   /**
    * Marker to be used in {@link Status#withCause(Throwable)} to signal that stream should be closed
    * by sending headers.

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

@@ -341,6 +341,7 @@ private void messagesAvailableInternal(final MessageProducer producer) {
                 e.getStatus().withCause(GrpcUtil.CLOSE_WITH_HEADERS), null));
             return;
           }
+          message.close();
           listener.onMessage(parsed);
         }
       } catch (Throwable t) {