We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 873ea3b commit 5ab225aCopy full SHA for 5ab225a
core/src/main/java/io/grpc/internal/MessageFramer.java
@@ -124,8 +124,6 @@ public void setMaxOutboundMessageSize(int maxSize) {
124
maxOutboundMessageSize = maxSize;
125
}
126
127
- private static final int COMPRESSION_MIN_LENGTH = 20;
128
-
129
/**
130
* Writes out a payload message.
131
*
@@ -143,7 +141,7 @@ public void writePayload(InputStream message) {
143
141
int messageLength = -2;
144
142
try {
145
messageLength = getKnownLength(message);
146
- if (messageLength >= COMPRESSION_MIN_LENGTH && compressed) {
+ if (messageLength != 0 && compressed) {
147
written = writeCompressed(message, messageLength);
148
} else {
149
written = writeUncompressed(message, messageLength);
0 commit comments