Searched refs:onReadyCalled (Results 1 – 5 of 5) sorted by relevance
88 final AtomicBoolean onReadyCalled = new AtomicBoolean(); in runtimeStreamObserverIsServerCallStreamObserver() local109 onReadyCalled.set(true); in runtimeStreamObserverIsServerCallStreamObserver()126 assertTrue(onReadyCalled.get()); in runtimeStreamObserverIsServerCallStreamObserver()260 final AtomicInteger onReadyCalled = new AtomicInteger(); in onReadyHandlerCalledForUnaryRequest() local271 onReadyCalled.incrementAndGet(); in onReadyHandlerCalledForUnaryRequest()282 assertEquals(0, onReadyCalled.get()); in onReadyHandlerCalledForUnaryRequest()285 assertEquals(0, onReadyCalled.get()); in onReadyHandlerCalledForUnaryRequest()288 assertEquals(1, onReadyCalled.get()); in onReadyHandlerCalledForUnaryRequest()291 assertEquals(2, onReadyCalled.get()); in onReadyHandlerCalledForUnaryRequest()
270 boolean onReadyCalled; in listener_onReadyDelayedUntilPassthrough() field in DelayedStreamTest.IsReadyListener276 onReadyCalled = true; in listener_onReadyDelayedUntilPassthrough()294 assertTrue(isReadyListener.onReadyCalled); in listener_onReadyDelayedUntilPassthrough()
523 final AtomicBoolean onReadyCalled = new AtomicBoolean(); in callerContextPropagatedToListener() local548 onReadyCalled.set(true); in callerContextPropagatedToListener()573 assertTrue(onReadyCalled.get()); in callerContextPropagatedToListener()
847 final AtomicBoolean onReadyCalled = new AtomicBoolean(false); in testCallContextIsBoundInListenerCallbacks() local870 onReadyCalled.set(true); in testCallContextIsBoundInListenerCallbacks()919 assertTrue(onReadyCalled.get()); in testCallContextIsBoundInListenerCallbacks()
1942 boolean onReadyCalled; field in OkHttpClientTransportTest.MockStreamListener1978 onReadyCalled = true; in onReady()1982 boolean value = onReadyCalled; in isOnReadyCalled()1983 onReadyCalled = false; in isOnReadyCalled()