@Test public void writeMessageShouldSendRequest() throws Exception { stream().id(STREAM_ID); byte[] msg = smallMessage(); stream.writeMessage(new ByteArrayInputStream(msg)); stream.flush(); verify(writeQueue).enqueue( eq(new SendGrpcFrameCommand(stream, messageFrame(MESSAGE), false)), any(ChannelPromise.class), eq(true)); }
@Override public Integer id() { return id; }
NettyClientStream extends Http2ClientStream { @Override public Integer id() { return id; } }
NettyClientStream extends Http2ClientStream { @Override public Integer id() { return id; } NettyClientStream(MethodDescriptor<?, ?> method, Metadata headers, Channel channel,
      NettyClientHandler handler, int maxMessageSize, AsciiString authority, AsciiString scheme); }
NettyClientStream extends Http2ClientStream { @Override public Integer id() { return id; } NettyClientStream(MethodDescriptor<?, ?> method, Metadata headers, Channel channel,
      NettyClientHandler handler, int maxMessageSize, AsciiString authority, AsciiString scheme); @Override void setAuthority(String authority); @Override void start(ClientStreamListener listener); @Override void request(int numMessages); @Override Integer id(); void id(int id); void setHttp2Stream(Http2Stream http2Stream); @Nullable Http2Stream http2Stream(); }
NettyClientStream extends Http2ClientStream { @Override public Integer id() { return id; } NettyClientStream(MethodDescriptor<?, ?> method, Metadata headers, Channel channel,
      NettyClientHandler handler, int maxMessageSize, AsciiString authority, AsciiString scheme); @Override void setAuthority(String authority); @Override void start(ClientStreamListener listener); @Override void request(int numMessages); @Override Integer id(); void id(int id); void setHttp2Stream(Http2Stream http2Stream); @Nullable Http2Stream http2Stream();  }