Searched refs:SIGNALLED (Results 1 – 5 of 5) sorted by relevance
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()
74 private const val SIGNALLED = -2L // already signalled subscriber onCompleted/onError constant196 …_nRequested.value = SIGNALLED // we'll signal onError/onCompleted (that the final state -- no CAS … in doLockedSignalCompleted()260 …if (current == SIGNALLED) return // some other thread holding lock already signalled cancellation/… in signalCompleted()
250 if (state.getAndSet(State.SIGNALLED) == State.READY) { in signal()278 if (isValid() && state.compareAndSet(State.SIGNALLED, State.READY)) { in reset()302 SIGNALLED enumConstant
55 private const val SIGNALLED = -2 // already signalled subscriber onCompleted/onError constant143 …_signal.value = SIGNALLED // we'll signal onError/onCompleted (that the final state -- no CAS need… in doLockedSignalCompleted()
69 private const val SIGNALLED = -2 // already signalled subscriber onCompleted/onError constant157 …_signal.value = SIGNALLED // we'll signal onError/onCompleted (that the final state -- no CAS need… in doLockedSignalCompleted()