### Question:
ForwardingClientStream implements ClientStream { @Override public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { delegate().setDecompressorRegistry(decompressorRegistry); }  @Override void request(int numMessages); @Override void writeMessage(InputStream message); @Override void flush(); @Override boolean isReady(); @Override void setCompressor(Compressor compressor); @Override void setMessageCompression(boolean enable); @Override void cancel(Status reason); @Override void halfClose(); @Override void setAuthority(String authority); @Override void setFullStreamDecompression(boolean fullStreamDecompression); @Override void setDecompressorRegistry(DecompressorRegistry decompressorRegistry); @Override void start(ClientStreamListener listener); @Override void setMaxInboundMessageSize(int maxSize); @Override void setMaxOutboundMessageSize(int maxSize); @Override void setDeadline(Deadline deadline); @Override Attributes getAttributes(); @Override String toString();  }### Answer:
@Test public void setDecompressorRegistryTest() { DecompressorRegistry decompressor = DecompressorRegistry.emptyInstance().with(new Decompressor() { @Override public String getMessageEncoding() { return "some-encoding"; } @Override public InputStream decompress(InputStream is) throws IOException { return is; } }, true); forward.setDecompressorRegistry(decompressor); verify(mock).setDecompressorRegistry(same(decompressor)); }