Skip to content

Commit a91ccc4

Browse files
committed
fix: add setMessageCompression override to AbstractClientStream and InProcessClientStream
NettyClientStream extends AbstractClientStream but compilation failed because AbstractClientStream did not override the new ClientStream.setMessageCompression(boolean, String) method added to the interface. The method was only on the inner TransportState class. Add the override to AbstractClientStream that delegates to transportState(), matching the pattern of setDecompressorRegistry. Also add the override to InProcessClientStream (noop, matching existing setMessageCompression(boolean)). Signed-off-by: jlaportebot <jlaportebot@gmail.com>
1 parent 1c39005 commit a91ccc4

2 files changed

Lines changed: 16 additions & 0 deletions

File tree

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

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,17 @@ public final void setDecompressorRegistry(DecompressorRegistry decompressorRegis
147147
transportState().setDecompressorRegistry(decompressorRegistry);
148148
}
149149

150+
/**
151+
* {@inheritDoc}
152+
*
153+
* <p>Delegates to the transport state so that subclasses (e.g., NettyClientStream,
154+
* InProcessClientStream) inherit the new implementation via their TransportState.
155+
*/
156+
@Override
157+
public void setMessageCompression(boolean enabled, String compressorName) {
158+
transportState().setMessageCompression(enabled, compressorName);
159+
}
160+
150161
/** {@inheritDoc} */
151162
@Override
152163
protected abstract TransportState transportState();

inprocess/src/main/java/io/grpc/inprocess/InProcessTransport.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -668,6 +668,11 @@ public void setMessageCompression(boolean enable) {
668668
// noop
669669
}
670670

671+
@Override
672+
public void setMessageCompression(boolean enabled, String compressorName) {
673+
// noop
674+
}
675+
671676
@Override
672677
public void optimizeForDirectExecutor() {}
673678

0 commit comments

Comments
 (0)