Searched refs:CANCELLED_BECAUSE_COMMITTED (Results 1 – 2 of 2) sorted by relevance
59 private static final Status CANCELLED_BECAUSE_COMMITTED = field in RetriableStream136 substream.stream.cancel(CANCELLED_BECAUSE_COMMITTED); in commit()247 substream.stream.cancel(CANCELLED_BECAUSE_COMMITTED); in drain()
77 private static final String CANCELLED_BECAUSE_COMMITTED = field in RetriableStreamTest477 assertEquals(CANCELLED_BECAUSE_COMMITTED, statusCaptor.getValue().getDescription()); in cancel_closed()516 assertEquals(CANCELLED_BECAUSE_COMMITTED, statusCaptor.getValue().getDescription()); in retry_cancel_closed()