Home
last modified time | relevance | path

Searched refs:cancellable (Results 1 – 25 of 31) sorted by relevance

12

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/
DCancellableContinuation.kt309 … val cancellable = CancellableContinuationImpl(uCont.intercepted(), resumeMode = MODE_CANCELLABLE) in suspendCancellableCoroutine() constant
315 cancellable.initCancellability() in suspendCancellableCoroutine()
316 block(cancellable) in suspendCancellableCoroutine()
317 cancellable.getResult() in suspendCancellableCoroutine()
327 val cancellable = getOrCreateCancellableContinuation(uCont.intercepted()) in suspendCancellableCoroutineReusable() constant
328 block(cancellable) in suspendCancellableCoroutineReusable()
329 cancellable.getResult() in suspendCancellableCoroutineReusable()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/operators/
DCancellableTest.kt26 flow.cancellable().launchIn(this).join() in <lambda>()
33 assertNotSame(flow, flow.cancellable()) in testFastPath()
36 assertSame(cancellableFlow, cancellableFlow.cancellable()) in testFastPath()
/external/llvm-project/mlir/lib/Dialect/Async/Transforms/
DAsyncRefCountingOptimization.cpp119 llvm::SmallDenseMap<Operation *, Operation *> cancellable; in optimizeReferenceCounting() local
129 if (cancellable.find(dropRef.getOperation()) != cancellable.end()) in optimizeReferenceCounting()
167 cancellable[dropRef.getOperation()] = addRef.getOperation(); in optimizeReferenceCounting()
176 for (auto &kv : cancellable) { in optimizeReferenceCounting()
/external/grpc-grpc-java/context/src/test/java/io/grpc/
DContextTest.java912 Context.CancellableContext cancellable = blue.withCancellation(); in cancellableAncestorIntegrationTest() local
913 assertNull(cancellable.cancellableAncestor); in cancellableAncestorIntegrationTest()
914 Context childOfCancel = cancellable.withValue(PET, "cat"); in cancellableAncestorIntegrationTest()
915 assertSame(cancellable, childOfCancel.cancellableAncestor); in cancellableAncestorIntegrationTest()
917 assertSame(cancellable, grandChildOfCancel.cancellableAncestor); in cancellableAncestorIntegrationTest()
920 assertSame(cancellable, cancellable2.cancellableAncestor); in cancellableAncestorIntegrationTest()
927 Context.CancellableContext cancellable = Context.current().withCancellation(); in cancellableAncestorFork() local
928 Context fork = cancellable.fork(); in cancellableAncestorFork()
934 Context.CancellableContext cancellable = Context.current().withCancellation(); in cancellableContext_closeCancelsWithNullCause() local
935 cancellable.close(); in cancellableContext_closeCancelsWithNullCause()
[all …]
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/
DChannelUndeliveredElementStressTest.kt67 private inline fun cancellable(done: Channel<Boolean>, block: () -> Unit) { in <lambda>() method in kotlinx.coroutines.channels.ChannelUndeliveredElementStressTest
154 cancellable(senderDone) { in <lambda>()
185 cancellable(receiverDone) { in <lambda>()
/external/kotlinx.coroutines/
Dcoroutines-guide.md19 …putation-code-cancellable'></a>[Making computation code cancellable](docs/cancellation-and-timeout…
21 …* <a name='run-non-cancellable-block'></a>[Run non-cancellable block](docs/cancellation-and-timeou…
86 …* <a name='making-busy-flow-cancellable'></a>[Making busy flow cancellable](docs/flow.md#making-bu…
DCHANGES.md38 and corresponding `Flow` operators are cancellable in non-atomic way (#1813).
96 * New `Flow.cancellable()` operator for cooperative cancellation (#2026).
97 * Emissions from `flow` builder now check cancellation status and are properly cancellable (#2026).
162 * Reusable cancellable continuations were introduced that improved the performance of various flow …
675 * This change is designed to allow better performance of suspending cancellable functions:
724 * Use fast path in `CompletionStage.await` and make it cancellable.
885 …* Fixed cancellable suspending functions to throw `CancellationException` (as was documented befor…
966 * Coroutines that are scheduled for execution are cancellable by default now
974 * `run` function is also cancellable in the same way and accepts an optional
1140 * Performance optimizations for cancellable continuations (fewer objects created).
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/
Dexample-flow-39.kt12 (1..5).asFlow().cancellable().collect { value -> in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/sharing/
DShareInFusionTest.kt19 assertSame(sh, (sh as Flow<*>).cancellable()) in <lambda>()
DStateInTest.kt19 assertSame(state, (state as Flow<*>).cancellable()) in <lambda>()
DStateFlowTest.kt160 assertSame(state, (state as Flow<*>).cancellable()) in <lambda>()
/external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/tailcall/
DSimpleChannelBenchmark.kt25 fun cancellable() = runBlocking { in <lambda>() method
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/
DLint.kt21 public fun <T> SharedFlow<T>.cancellable(): Flow<T> = noImpl() method
DContext.kt257 public fun <T> Flow<T>.cancellable(): Flow<T> = in cancellable() method
/external/kotlinx.coroutines/integration/kotlinx-coroutines-play-services/
DREADME.md9 | [Task.await][await] | Awaits for completion of the Task (cancellable)
/external/libiio/src/
Dnetwork.c72 bool cancellable; member
152 if (!io_ctx->cancellable) in wait_cancellable()
301 if (!io_ctx->cancellable) in wait_cancellable()
488 if (io_ctx->cancellable) in network_recv()
518 if (io_ctx->cancellable) in network_send()
743 ppdata->io_ctx.cancellable = false; in network_open()
758 ppdata->io_ctx.cancellable = true; in network_open()
/external/llvm-project/openmp/runtime/src/
Dkmp_barrier.cpp45 template <bool cancellable = false>
104 if (cancellable) { in __kmp_linear_barrier_gather_template()
152 template <bool cancellable = false>
214 if (cancellable) { in __kmp_linear_barrier_release_template()
1268 template <bool cancellable> struct is_cancellable {};
1292 template <bool cancellable = false>
1302 is_cancellable<cancellable> cancelled; in __kmp_barrier_template()
1391 if (cancellable) { in __kmp_barrier_template()
1504 if (cancellable) { in __kmp_barrier_template()
1591 if (cancellable) in __kmp_barrier_template()
/external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/test/future/
DFutureTest.kt306 …private suspend fun CoroutineScope.awaitFutureWithCancel(cancellable: Boolean): CompletableFuture<… in <lambda>()
315 if (cancellable) future.await() in <lambda>()
/external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/test/
DListenableFutureTest.kt549 …private suspend fun CoroutineScope.awaitFutureWithCancel(cancellable: Boolean): ListenableFuture<I… in <lambda>()
555 if (cancellable) future.await() in <lambda>()
/external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/
DREADME.md15 ….common.util.concurrent.ListenableFuture.await] | Awaits for completion of the future (cancellable)
/external/grpc-grpc/summerofcode/
Dideas.md24 1. [Make channel-connectivity-watching cancellable](https://github.com/grpc/grpc/issues/3064). Anyt…
/external/rust/crates/grpcio-sys/grpc/summerofcode/
Dideas.md24 1. [Make channel-connectivity-watching cancellable](https://github.com/grpc/grpc/issues/3064). Anyt…
/external/kotlinx.coroutines/kotlinx-coroutines-core/
DREADME.md102 …otlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-non-cancellable.html
111 …io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/suspend-cancellable-coroutine.html
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/
DREADME.md111 …otlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-non-cancellable.html
120 …io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/suspend-cancellable-coroutine.html
/external/llvm-project/clang-tools-extra/clangd/
DProtocol.h583 bool cancellable = false; member
611 llvm::Optional<bool> cancellable; member

12