Searched refs:retriableStreamRecorder (Results 1 – 1 of 1) sorted by relevance
115 private final RetriableStreamRecorder retriableStreamRecorder = field in RetriableStreamTest156 retriableStreamRecorder.postCommit(); in postCommit()165 return retriableStreamRecorder.newSubstream(actualPreviousRpcAttemptsInHeader); in newSubstream()170 return retriableStreamRecorder.prestart(); in prestart()196 doReturn(mockStream1).when(retriableStreamRecorder).newSubstream(0); in retry_everythingDrained()198 inOrder(retriableStreamRecorder, masterListener, mockStream1, mockStream2, mockStream3); in retry_everythingDrained()216 inOrder.verify(retriableStreamRecorder).prestart(); in retry_everythingDrained()217 inOrder.verify(retriableStreamRecorder).newSubstream(0); in retry_everythingDrained()250 doReturn(mockStream2).when(retriableStreamRecorder).newSubstream(1); in retry_everythingDrained()263 inOrder.verify(retriableStreamRecorder).newSubstream(1); in retry_everythingDrained()[all …]