@Test public void setMessageCompression() { call.setMessageCompression(true); verify(stream).setMessageCompression(true); }
@Override public void setMessageCompression(boolean enable) { stream.setMessageCompression(enable); }
ServerCallImpl extends ServerCall<ReqT, RespT> { @Override public void setMessageCompression(boolean enable) { stream.setMessageCompression(enable); } }
ServerCallImpl extends ServerCall<ReqT, RespT> { @Override public void setMessageCompression(boolean enable) { stream.setMessageCompression(enable); } ServerCallImpl(ServerStream stream, MethodDescriptor<ReqT, RespT> method,
      Metadata inboundHeaders, Context.CancellableContext context,
      DecompressorRegistry decompressorRegistry, CompressorRegistry compressorRegistry,
      CallTracer serverCallTracer); }
ServerCallImpl extends ServerCall<ReqT, RespT> { @Override public void setMessageCompression(boolean enable) { stream.setMessageCompression(enable); } ServerCallImpl(ServerStream stream, MethodDescriptor<ReqT, RespT> method,
      Metadata inboundHeaders, Context.CancellableContext context,
      DecompressorRegistry decompressorRegistry, CompressorRegistry compressorRegistry,
      CallTracer serverCallTracer); @Override void request(int numMessages); @Override void sendHeaders(Metadata headers); @Override void sendMessage(RespT message); @Override void setMessageCompression(boolean enable); @Override void setCompression(String compressorName); @Override boolean isReady(); @Override void close(Status status, Metadata trailers); @Override boolean isCancelled(); @Override Attributes getAttributes(); @Override String getAuthority(); @Override MethodDescriptor<ReqT, RespT> getMethodDescriptor(); }
ServerCallImpl extends ServerCall<ReqT, RespT> { @Override public void setMessageCompression(boolean enable) { stream.setMessageCompression(enable); } ServerCallImpl(ServerStream stream, MethodDescriptor<ReqT, RespT> method,
      Metadata inboundHeaders, Context.CancellableContext context,
      DecompressorRegistry decompressorRegistry, CompressorRegistry compressorRegistry,
      CallTracer serverCallTracer); @Override void request(int numMessages); @Override void sendHeaders(Metadata headers); @Override void sendMessage(RespT message); @Override void setMessageCompression(boolean enable); @Override void setCompression(String compressorName); @Override boolean isReady(); @Override void close(Status status, Metadata trailers); @Override boolean isCancelled(); @Override Attributes getAttributes(); @Override String getAuthority(); @Override MethodDescriptor<ReqT, RespT> getMethodDescriptor();  }