Searched refs:finalState (Results 1 – 5 of 5) sorted by relevance
219 val finalState = when { in <lambda>() constant230 if (handled) (finalState as CompletedExceptionally).makeHandled() in <lambda>()235 onCompletionInternal(finalState) in <lambda>()237 val casSuccess = _state.compareAndSet(state, finalState.boxIncomplete()) in <lambda>()240 completeStateFinalization(state, finalState) in <lambda>()241 return finalState in <lambda>()660 var finalState: Any? = COMPLETING_ALREADY in <lambda>() variable664 finalState = cancelMakeCompleting(cause) in <lambda>()665 if (finalState === COMPLETING_WAITING_CHILDREN) return true in <lambda>()667 if (finalState === COMPLETING_ALREADY) { in <lambda>()[all …]
291 protected boolean tryReleaseShared(int finalState) { in tryReleaseShared() argument292 setState(finalState); in tryReleaseShared()387 private boolean complete(@Nullable V v, @Nullable Throwable t, int finalState) { in complete() argument395 ((finalState & (CANCELLED | INTERRUPTED)) != 0) in complete()398 releaseShared(finalState); in complete()
291 protected boolean tryReleaseShared(int finalState) { in tryReleaseShared() argument292 setState(finalState); in tryReleaseShared()387 private boolean complete(@NullableDecl V v, @NullableDecl Throwable t, int finalState) { in complete() argument395 ((finalState & (CANCELLED | INTERRUPTED)) != 0) in complete()398 releaseShared(finalState); in complete()
753 final State finalState = shadowMediaPlayer.getState(); in test() local754 assertThat(finalState).isSameInstanceAs(ERROR); in test()782 final State finalState = shadowMediaPlayer.getState(); in test()783 assertThat(finalState).isSameInstanceAs(state); in test()806 final State finalState = shadowMediaPlayer.getState(); in testMethodSuccess() local808 assertThat(finalState).isEqualTo(state); in testMethodSuccess()810 assertThat(finalState).isEqualTo(next); in testMethodSuccess()
251 def finalState(self, tokens): member in GenericParser327 finalitem = (self.finalState(tokens), 0)