@Test public void writeMessageShouldSendRequestUnknownLength() throws Exception { stream().transportState().setId(STREAM_ID); byte[] msg = smallMessage(); stream.writeMessage(new BufferedInputStream(new ByteArrayInputStream(msg))); stream.flush(); verify(writeQueue).enqueue( eq(new SendGrpcFrameCommand( stream.transportState(), messageFrame(MESSAGE).slice(0, 5), false)), eq(false)); verify(writeQueue).enqueue( eq(new SendGrpcFrameCommand( stream.transportState(), messageFrame(MESSAGE).slice(5, 11), false)), eq(true)); }
@Override protected TransportState transportState() { return state; }
NettyClientStream extends AbstractClientStream { @Override protected TransportState transportState() { return state; } }
NettyClientStream extends AbstractClientStream { @Override protected TransportState transportState() { return state; } NettyClientStream(
      TransportState state,
      MethodDescriptor<?, ?> method,
      Metadata headers,
      Channel channel,
      AsciiString authority,
      AsciiString scheme,
      AsciiString userAgent,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer,
      CallOptions callOptions); }
NettyClientStream extends AbstractClientStream { @Override protected TransportState transportState() { return state; } NettyClientStream(
      TransportState state,
      MethodDescriptor<?, ?> method,
      Metadata headers,
      Channel channel,
      AsciiString authority,
      AsciiString scheme,
      AsciiString userAgent,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer,
      CallOptions callOptions); @Override void setAuthority(String authority); @Override Attributes getAttributes(); }
NettyClientStream extends AbstractClientStream { @Override protected TransportState transportState() { return state; } NettyClientStream(
      TransportState state,
      MethodDescriptor<?, ?> method,
      Metadata headers,
      Channel channel,
      AsciiString authority,
      AsciiString scheme,
      AsciiString userAgent,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer,
      CallOptions callOptions); @Override void setAuthority(String authority); @Override Attributes getAttributes();  }