| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ConnectivityStateManagerTest.java | 61 state.notifyWhenStateChanged(new Runnable() { in registerCallbackBeforeStateChanged()
83 state.notifyWhenStateChanged(new Runnable() { in registerCallbackAfterStateChanged()
100 state.notifyWhenStateChanged(new Runnable() { in callbackOnlyCalledOnTransition()
121 state.notifyWhenStateChanged(callback, executor.getScheduledExecutorService(), IDLE); in callbacksAreOneShot()
135 state.notifyWhenStateChanged( in callbacksAreOneShot()
151 state.notifyWhenStateChanged(new Runnable() { in multipleCallbacks()
158 state.notifyWhenStateChanged(new Runnable() { in multipleCallbacks()
165 state.notifyWhenStateChanged(new Runnable() { in multipleCallbacks()
199 state.notifyWhenStateChanged(newRecursiveCallback(executor), executor, state.getState()); in newRecursiveCallback()
206 state.notifyWhenStateChanged(newRecursiveCallback(executor.getScheduledExecutorService()),
[all …]
|
| D | ForwardingManagedChannelTest.java | 110 public void notifyWhenStateChanged() { in notifyWhenStateChanged() method in ForwardingManagedChannelTest
115 forward.notifyWhenStateChanged(ConnectivityState.READY, callback); in notifyWhenStateChanged()
116 verify(mock).notifyWhenStateChanged(same(ConnectivityState.READY), same(callback)); in notifyWhenStateChanged()
|
| D | ManagedChannelImplTest.java | 1605 public void notifyWhenStateChanged() { in notifyWhenStateChanged() method in ManagedChannelImplTest
1619 channel.notifyWhenStateChanged(IDLE, onStateChanged); in notifyWhenStateChanged()
1631 channel.notifyWhenStateChanged(IDLE, onStateChanged); in notifyWhenStateChanged()
1651 channel.notifyWhenStateChanged(IDLE, onStateChanged); in channelStateWhenChannelShutdown()
1661 channel.notifyWhenStateChanged(SHUTDOWN, onStateChanged); in channelStateWhenChannelShutdown()
2031 channel.notifyWhenStateChanged(IDLE, onStateChanged); in updateBalancingStateWithShutdownShouldBeIgnored()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | ForwardingManagedChannel.java | 77 public void notifyWhenStateChanged(ConnectivityState source, Runnable callback) { in notifyWhenStateChanged() method in ForwardingManagedChannel
78 delegate.notifyWhenStateChanged(source, callback); in notifyWhenStateChanged()
|
| D | ConnectivityStateManager.java | 45 void notifyWhenStateChanged(Runnable callback, Executor executor, ConnectivityState source) { in notifyWhenStateChanged() method in ConnectivityStateManager
|
| D | ManagedChannelImpl.java | 874 public void notifyWhenStateChanged(final ConnectivityState source, final Runnable callback) { in notifyWhenStateChanged() method in ManagedChannelImpl
879 channelStateManager.notifyWhenStateChanged(callback, executor, source); in notifyWhenStateChanged()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/ |
| D | ManagedChannel.java | 109 public void notifyWhenStateChanged(ConnectivityState source, Runnable callback) { in notifyWhenStateChanged() method in ManagedChannel
|
| /external/grpc-grpc-java/android/src/main/java/io/grpc/android/ |
| D | AndroidChannelBuilder.java | 302 public void notifyWhenStateChanged(ConnectivityState source, Runnable callback) { in notifyWhenStateChanged() method in AndroidChannelBuilder.AndroidChannel
303 delegate.notifyWhenStateChanged(source, callback); in notifyWhenStateChanged()
|