@Test public void start_alreadyCancelled() { stream.start(new BaseClientStreamListener()); stream.cancel(Status.CANCELLED); stream.transportState().start(1234); verifyNoMoreInteractions(frameWriter); }
@Override protected TransportState transportState() { return state; }
OkHttpClientStream extends AbstractClientStream { @Override protected TransportState transportState() { return state; } }
OkHttpClientStream extends AbstractClientStream { @Override protected TransportState transportState() { return state; } OkHttpClientStream(
      MethodDescriptor<?, ?> method,
      Metadata headers,
      AsyncFrameWriter frameWriter,
      OkHttpClientTransport transport,
      OutboundFlowController outboundFlow,
      Object lock,
      int maxMessageSize,
      int initialWindowSize,
      String authority,
      String userAgent,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer,
      CallOptions callOptions); }
OkHttpClientStream extends AbstractClientStream { @Override protected TransportState transportState() { return state; } OkHttpClientStream(
      MethodDescriptor<?, ?> method,
      Metadata headers,
      AsyncFrameWriter frameWriter,
      OkHttpClientTransport transport,
      OutboundFlowController outboundFlow,
      Object lock,
      int maxMessageSize,
      int initialWindowSize,
      String authority,
      String userAgent,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer,
      CallOptions callOptions); MethodDescriptor.MethodType getType(); int id(); @Override void setAuthority(String authority); @Override Attributes getAttributes(); }
OkHttpClientStream extends AbstractClientStream { @Override protected TransportState transportState() { return state; } OkHttpClientStream(
      MethodDescriptor<?, ?> method,
      Metadata headers,
      AsyncFrameWriter frameWriter,
      OkHttpClientTransport transport,
      OutboundFlowController outboundFlow,
      Object lock,
      int maxMessageSize,
      int initialWindowSize,
      String authority,
      String userAgent,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer,
      CallOptions callOptions); MethodDescriptor.MethodType getType(); int id(); @Override void setAuthority(String authority); @Override Attributes getAttributes(); static final int ABSENT_ID; }