Searched refs:sublistenerCaptor1 (Results 1 – 1 of 1) sorted by relevance
229 ArgumentCaptor<ClientStreamListener> sublistenerCaptor1 = in retry_everythingDrained() local231 inOrder.verify(mockStream1).start(sublistenerCaptor1.capture()); in retry_everythingDrained()251 sublistenerCaptor1.getValue().closed(Status.fromCode(RETRIABLE_STATUS_CODE_2), new Metadata()); in retry_everythingDrained()349 ArgumentCaptor<ClientStreamListener> sublistenerCaptor1 = in headersRead_cancel() local351 verify(mockStream1).start(sublistenerCaptor1.capture()); in headersRead_cancel()353 sublistenerCaptor1.getValue().headersRead(new Metadata()); in headersRead_cancel()370 ArgumentCaptor<ClientStreamListener> sublistenerCaptor1 = in retry_headersRead_cancel() local372 verify(mockStream1).start(sublistenerCaptor1.capture()); in retry_headersRead_cancel()377 sublistenerCaptor1.getValue().closed(Status.fromCode(RETRIABLE_STATUS_CODE_1), new Metadata()); in retry_headersRead_cancel()405 ArgumentCaptor<ClientStreamListener> sublistenerCaptor1 = in headersRead_closed() local[all …]