@Test public void cancelStreamShouldSucceed() { stream().cancel(Status.DEADLINE_EXCEEDED); verify(writeQueue).enqueue( new CancelServerStreamCommand(stream().transportState(), Status.DEADLINE_EXCEEDED), true); }
@Override protected TransportState transportState() { return state; }
NettyServerStream extends AbstractServerStream { @Override protected TransportState transportState() { return state; } }
NettyServerStream extends AbstractServerStream { @Override protected TransportState transportState() { return state; } NettyServerStream(
      Channel channel,
      TransportState state,
      Attributes transportAttrs,
      String authority,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer); }
NettyServerStream extends AbstractServerStream { @Override protected TransportState transportState() { return state; } NettyServerStream(
      Channel channel,
      TransportState state,
      Attributes transportAttrs,
      String authority,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer); @Override Attributes getAttributes(); @Override String getAuthority(); }
NettyServerStream extends AbstractServerStream { @Override protected TransportState transportState() { return state; } NettyServerStream(
      Channel channel,
      TransportState state,
      Attributes transportAttrs,
      String authority,
      StatsTraceContext statsTraceCtx,
      TransportTracer transportTracer); @Override Attributes getAttributes(); @Override String getAuthority();  }