Searched refs:SIGNALLED (Results 1 – 5 of 5) sorted by relevance
61 private const val SIGNALLED = -2L // already signalled subscriber onCompleted/onError constant236 if (_nRequested.value == SIGNALLED) in doLockedSignalCompleted()238 …_nRequested.value = SIGNALLED // we'll signal onError/onCompleted (the final state, so no CAS need… in doLockedSignalCompleted()299 …if (current == SIGNALLED) return // some other thread holding lock already signalled cancellation/… in signalCompleted()
55 private const val SIGNALLED = -2 // already signalled subscriber onCompleted/onError constant165 if (_signal.value == SIGNALLED) in doLockedSignalCompleted()167 …_signal.value = SIGNALLED // we'll signal onError/onCompleted (that the final state -- no CAS need… in doLockedSignalCompleted()
20 import static com.google.common.jimfs.AbstractWatchService.Key.State.SIGNALLED;114 assertThat(key.state()).isEqualTo(SIGNALLED); in testKeyStates()119 assertThat(key.state()).isEqualTo(SIGNALLED); in testKeyStates()159 assertThat(key.state()).isEqualTo(SIGNALLED); in testKeyRequeuedOnResetIfEventsArePending()
250 if (state.getAndSet(State.SIGNALLED) == State.READY) { in signal()278 if (isValid() && state.compareAndSet(State.SIGNALLED, State.READY)) { in reset()302 SIGNALLED enumConstant