Searched refs:sublistenerCaptor3 (Results 1 – 1 of 1) sorted by relevance
321 ArgumentCaptor<ClientStreamListener> sublistenerCaptor3 = in retry_everythingDrained() local323 inOrder.verify(mockStream3).start(sublistenerCaptor3.capture()); in retry_everythingDrained()333 sublistenerCaptor3.getValue().closed( in retry_everythingDrained()1005 ArgumentCaptor<ClientStreamListener> sublistenerCaptor3 = in expBackoff_maxBackoff_maxRetryAttempts() local1007 inOrder.verify(mockStream3).start(sublistenerCaptor3.capture()); in expBackoff_maxBackoff_maxRetryAttempts()1011 sublistenerCaptor3.getValue().closed(Status.fromCode(RETRIABLE_STATUS_CODE_1), new Metadata()); in expBackoff_maxBackoff_maxRetryAttempts()1109 ArgumentCaptor<ClientStreamListener> sublistenerCaptor3 = in pushback() local1111 inOrder.verify(mockStream3).start(sublistenerCaptor3.capture()); in pushback()1115 sublistenerCaptor3.getValue().closed(Status.fromCode(RETRIABLE_STATUS_CODE_1), new Metadata()); in pushback()1428 ArgumentCaptor<ClientStreamListener> sublistenerCaptor3 = in transparentRetry() local[all …]