NettyServerStream extends AbstractServerStream<Integer> { @Override public void cancel(Status status) { writeQueue.enqueue(new CancelServerStreamCommand(this, status), true); } NettyServerStream(Channel channel, Http2Stream http2Stream, NettyServerHandler handler,
                    int maxMessageSize); @Override Integer id(); @Override void request(final int numMessages); @Override void cancel(Status status); @Override Attributes attributes();  }
@Test public void cancelStreamShouldSucceed() { stream().cancel(Status.DEADLINE_EXCEEDED); verify(writeQueue).enqueue( new CancelServerStreamCommand(stream(), Status.DEADLINE_EXCEEDED), true); }