with cause initially

Author: panchenko

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

@@ -521,6 +521,7 @@ private void verifySize() {
       if (count > maxMessageSize) {
         throw Status.RESOURCE_EXHAUSTED
             .withDescription("Decompressed gRPC message exceeds maximum size " + maxMessageSize)
+            .withCause(new CloseWithHeadersMarker())
             .asRuntimeException();
       }
     }

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

@@ -337,8 +337,7 @@ private void messagesAvailableInternal(final MessageProducer producer) {
             GrpcUtil.closeQuietly(message);
             GrpcUtil.closeQuietly(producer);
             call.cancelled = true;
-            call.handleInternalError(InternalStatus.asRuntimeExceptionWithoutStacktrace(
-                e.getStatus().withCause(new CloseWithHeadersMarker()), null));
+            call.handleInternalError(e);
             return;
           }
           message.close();