Searched refs:listener3 (Results 1 – 1 of 1) sorted by relevance
1038 final MockStreamListener listener3 = new MockStreamListener(); in pendingStreamFailedByIdExhausted() local1050 stream3.start(listener3); in pendingStreamFailedByIdExhausted()1059 listener3.waitUntilStreamClosed(); in pendingStreamFailedByIdExhausted()1060 assertEquals(Status.UNAVAILABLE.getCode(), listener3.status.getCode()); in pendingStreamFailedByIdExhausted()1713 MockStreamListener listener3 = new MockStreamListener(); in goAway_streamListenerRpcProgress() local1722 stream3.start(listener3); in goAway_streamListenerRpcProgress()1733 listener3.waitUntilStreamClosed(); in goAway_streamListenerRpcProgress()1736 assertEquals(REFUSED, listener3.rpcProgress); in goAway_streamListenerRpcProgress()1753 MockStreamListener listener3 = new MockStreamListener(); in reset_streamListenerRpcProgress() local1762 stream3.start(listener3); in reset_streamListenerRpcProgress()[all …]