diff --git a/core/src/main/java/com/google/net/stubby/transport/AbstractStream.java b/core/src/main/java/com/google/net/stubby/transport/AbstractStream.java index 6e3bf7773d..4083a52ba9 100644 --- a/core/src/main/java/com/google/net/stubby/transport/AbstractStream.java +++ b/core/src/main/java/com/google/net/stubby/transport/AbstractStream.java @@ -104,6 +104,9 @@ public abstract class AbstractStream implements Stream { new GrpcDeframer(decompressor, inboundMessageHandler, deframerExecutor, listener); this.deframer2 = null; } else { + if (decompressor != null) { + decompressor.close(); + } framer = new MessageFramer2(outboundFrameHandler, 4096); this.deframer = null; this.deframer2 = new MessageDeframer2(inboundMessageHandler, deframerExecutor, listener); diff --git a/lib/libtest_proto_grpc.jar b/lib/libtest_proto_grpc.jar index 9b1c90652f..ebc760f8b3 100644 Binary files a/lib/libtest_proto_grpc.jar and b/lib/libtest_proto_grpc.jar differ