Searched refs:cancelStream (Results 1 – 6 of 6) sorted by relevance
199 cancelStream(Status.CANCELLED); in cancelBufferedStreamShouldChangeClientStreamStatus()215 cancelStream(Status.CANCELLED); in cancelShouldSucceed()227 cancelStream(Status.DEADLINE_EXCEEDED); in cancelDeadlineExceededShouldSucceed()241 ChannelFuture cancelFuture = cancelStream(Status.CANCELLED); in cancelWhileBufferedShouldSucceed()256 cancelStream(Status.CANCELLED); in cancelTwiceShouldSucceed()261 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceShouldSucceed()269 cancelStream(Status.DEADLINE_EXCEEDED); in cancelTwiceDifferentReasons()274 ChannelFuture future = cancelStream(Status.CANCELLED); in cancelTwiceDifferentReasons()466 cancelStream(Status.CANCELLED); in cancelStreamShouldCreateAndThenFailBufferedStream()690 private ChannelFuture cancelStream(Status status) throws Exception { in cancelStream() method in NettyClientHandlerTest
304 cancelStream(ctx, (CancelClientStreamCommand) msg, promise); in write()561 private void cancelStream(ChannelHandlerContext ctx, CancelClientStreamCommand cmd, in cancelStream() method in NettyClientHandler
577 cancelStream(ctx, (CancelServerStreamCommand) msg, promise); in write()641 private void cancelStream(ChannelHandlerContext ctx, CancelServerStreamCommand cmd, in cancelStream() method in NettyServerHandler
246 cs.cancelStream()251 func (cs *clientStream) cancelStream() { func
496 public void cancelStream() { in cancelStream() method in CronetClientStreamTest
470 public void cancelStream() throws Exception { in cancelStream() method in OkHttpClientTransportTest