@Test public void abortStreamAndNotSendStatus() throws Exception { Status status = Status.INTERNAL.withCause(new Throwable()); stream().transportState().transportReportStatus(status); verify(serverListener).closed(same(status)); verify(channel, never()).writeAndFlush(any(SendResponseHeadersCommand.class)); verify(channel, never()).writeAndFlush(any(SendGrpcFrameCommand.class)); assertNull("no message expected", listenerMessageQueue.poll()); }
@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();  }