Searched refs:_nRequested (Results 1 – 1 of 1) sorted by relevance
88 private val _nRequested = atomic(0L) // < 0 when closed (CLOSED or SIGNALLED) constant163 val current = _nRequested.value in doLockedNext()167 if (_nRequested.compareAndSet(current, updated)) { in doLockedNext()195 if (_nRequested.value >= CLOSED) { in doLockedSignalCompleted()196 …_nRequested.value = SIGNALLED // we'll signal onError/onCompleted (that the final state -- no CAS … in doLockedSignalCompleted()240 val cur = _nRequested.value in request()246 if (_nRequested.compareAndSet(cur, upd)) { in request()259 val current = _nRequested.value in signalCompleted()262 if (!_nRequested.compareAndSet(current, CLOSED)) continue // retry on failed CAS in signalCompleted()