Searched refs:coroutines (Results 1 – 25 of 1111) sorted by relevance
12345678910>>...45
1 # Module kotlinx-coroutines-core3 Core primitives to work with coroutines.11 …][kotlinx.coroutines.channels.produce] | [ReceiveChannel][kotlinx.coroutines.channels.ReceiveC…28 Synchronization primitives for coroutines:32 | [Mutex][kotlinx.coroutines.sync.Mutex] | [lock][kotlinx.coroutines.sync.Mutex.lock] …33 … [Channel][kotlinx.coroutines.channels.Channel] | [send][kotlinx.coroutines.channels.SendChannel.…51 [Select][kotlinx.coroutines.selects.select] expression waits for the result of multiple suspending …57 …coroutines.channels.SendChannel] | [send][kotlinx.coroutines.channels.SendChannel.send] …58 …coroutines.channels.ReceiveChannel] | [receive][kotlinx.coroutines.channels.ReceiveChannel.receive…59 …coroutines.channels.ReceiveChannel] | [receiveOrNull][kotlinx.coroutines.channels.receiveOrNull] |…[all …]
1 # Module kotlinx-coroutines-core3 Core primitives to work with coroutines available on all platforms.11 …][kotlinx.coroutines.channels.produce] | [ReceiveChannel][kotlinx.coroutines.channels.ReceiveC…12 …[actor][kotlinx.coroutines.channels.actor] | [SendChannel][kotlinx.coroutines.channels.SendCha…31 Synchronization primitives for coroutines:35 | [Mutex][kotlinx.coroutines.sync.Mutex] | [lock][kotlinx.coroutines.sync.Mutex.lock] …36 … [Channel][kotlinx.coroutines.channels.Channel] | [send][kotlinx.coroutines.channels.SendChannel.…54 [Select][kotlinx.coroutines.selects.select] expression waits for the result of multiple suspending …60 …coroutines.channels.SendChannel] | [send][kotlinx.coroutines.channels.SendChannel.send] …61 …coroutines.channels.ReceiveChannel] | [receive][kotlinx.coroutines.channels.ReceiveChannel.receive…[all …]
1 …nx/coroutines/AbstractCoroutine : kotlinx/coroutines/JobSupport, kotlin/coroutines/Continuation, k…2 protected final field parentContext Lkotlin/coroutines/CoroutineContext;3 public fun <init> (Lkotlin/coroutines/CoroutineContext;Z)V4 …public synthetic fun <init> (Lkotlin/coroutines/CoroutineContext;ZILkotlin/jvm/internal/DefaultCon…7 public final fun getContext ()Lkotlin/coroutines/CoroutineContext;8 public fun getCoroutineContext ()Lkotlin/coroutines/CoroutineContext;15 …public final fun start (Lkotlinx/coroutines/CoroutineStart;Ljava/lang/Object;Lkotlin/jvm/functions…16 public final fun start (Lkotlinx/coroutines/CoroutineStart;Lkotlin/jvm/functions/Function1;)V19 public final class kotlinx/coroutines/AwaitKt {20 …public static final fun awaitAll (Ljava/util/Collection;Lkotlin/coroutines/Continuation;)Ljava/lan…[all …]
1 # kotlinx.coroutines 5 …es/kotlin/kotlinx/kotlinx.coroutines/images/download.svg?version=1.4.1) ](https://bintray.com/kotl…7 …ields.io/badge/chat-slack-green.svg?logo=slack)](https://kotlinlang.slack.com/messages/coroutines/)9 Library support for Kotlin coroutines with [multiplatform](#multiplatform) support.22 > Play with coroutines online [here](https://pl.kotl.in/hG_tKbid_)26 * [core](kotlinx-coroutines-core/README.md) — common coroutines across all platforms:28 … for Android/Swing/JavaFx, and [Default][Dispatchers.Default] dispatcher for background coroutines;34 * [SupervisorJob()] and [CoroutineExceptionHandler] for supervision of coroutines hierarchies;36 * [core/jvm](kotlinx-coroutines-core/jvm/) — additional core features available on Kotlin/JVM:37 * [Dispatchers.IO] dispatcher for blocking coroutines;[all …]
15 rootProject.name = 'kotlinx.coroutines'30 include "kotlinx-coroutines-core"32 module('kotlinx-coroutines-test')33 module('kotlinx-coroutines-debug')35 module('kotlinx-coroutines-bom')38 module('integration/kotlinx-coroutines-guava')39 module('integration/kotlinx-coroutines-jdk8')40 module('integration/kotlinx-coroutines-slf4j')41 module('integration/kotlinx-coroutines-play-services')43 module('reactive/kotlinx-coroutines-reactive')[all …]
1 # Module kotlinx-coroutines-reactor14 [kotlinx-coroutines-reactive](../kotlinx-coroutines-reactive) module.22 This adapter is integrated with Reactor's `Context` and coroutines' [ReactorContext].28 | [Job.asMono][kotlinx.coroutines.Job.asMono] | Converts a job to a hot Mono29 | [Deferred.asMono][kotlinx.coroutines.Deferred.asMono] | Converts a deferred value to a hot Mono30 | [ReceiveChannel.asFlux][kotlinx.coroutines.channels.ReceiveChannel.asFlux] | Converts a streaming…33 <!--- MODULE kotlinx-coroutines-core -->34 <!--- INDEX kotlinx.coroutines -->35 …CoroutineScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corou…36 …tineDispatcher]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corou…[all …]
1 # Module kotlinx-coroutines-rx242 [kotlinx-coroutines-reactive](../kotlinx-coroutines-reactive) module.48 | [Job.asCompletable][kotlinx.coroutines.Job.asCompletable] | Converts job to hot completable49 | [Deferred.asSingle][kotlinx.coroutines.Deferred.asSingle] | Converts deferred value to hot single50 | [ReceiveChannel.asObservable][kotlinx.coroutines.channels.ReceiveChannel.asObservable] | Converts…53 <!--- MODULE kotlinx-coroutines-core -->54 <!--- INDEX kotlinx.coroutines -->55 …CoroutineScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corou…56 …tineDispatcher]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corou…57 <!--- INDEX kotlinx.coroutines.channels -->[all …]
2 title: kotlinx-coroutines6 # kotlinx.coroutines reference documentation8 Library support for Kotlin coroutines. This reference is a companion to 9 [Guide to kotlinx.coroutines by example](https://github.com/Kotlin/kotlinx.coroutines/blob/master/c…15 | [kotlinx-coroutines-core](kotlinx-coroutines-core) | Core primitives to work wi…16 | [kotlinx-coroutines-debug](kotlinx-coroutines-debug) | Debugging utilities for co…17 | [kotlinx-coroutines-test](kotlinx-coroutines-test) | Test primitives for corout…18 | [kotlinx-coroutines-reactive](kotlinx-coroutines-reactive) | Utilities for [Reactive St…19 | [kotlinx-coroutines-reactor](kotlinx-coroutines-reactor) | Utilities for [Reactor](ht…20 | [kotlinx-coroutines-rx2](kotlinx-coroutines-rx2) | Utilities for [RxJava 2.x]…[all …]
1 # Module kotlinx-coroutines-rx340 [kotlinx-coroutines-reactive](../kotlinx-coroutines-reactive) module.46 | [Job.asCompletable][kotlinx.coroutines.Job.asCompletable] | Converts job to hot completable47 | [Deferred.asSingle][kotlinx.coroutines.Deferred.asSingle] | Converts deferred value to hot single50 <!--- MODULE kotlinx-coroutines-core -->51 <!--- INDEX kotlinx.coroutines -->52 …CoroutineScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corou…53 …tineDispatcher]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corou…54 <!--- INDEX kotlinx.coroutines.channels -->55 [ProducerScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corout…[all …]
1 public final class kotlinx/coroutines/rx2/RxAwaitKt {2 …public static final fun await (Lio/reactivex/CompletableSource;Lkotlin/coroutines/Continuation;)Lj…3 …public static final fun await (Lio/reactivex/MaybeSource;Lkotlin/coroutines/Continuation;)Ljava/la…4 …public static final fun await (Lio/reactivex/SingleSource;Lkotlin/coroutines/Continuation;)Ljava/l…5 …public static final fun awaitFirst (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation…6 …rstOrDefault (Lio/reactivex/ObservableSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Lj…7 …Lio/reactivex/ObservableSource;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Lj…8 …public static final fun awaitFirstOrNull (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Contin…9 …public static final fun awaitLast (Lio/reactivex/ObservableSource;Lkotlin/coroutines/Continuation;…10 …un awaitOrDefault (Lio/reactivex/MaybeSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Lj…[all …]
... coroutines/ kotlin/coroutines/experimental/ kotlin/coroutines/experimental/AbstractCoroutineContextElement.class CoroutineContextImpl.kt package ...
... coroutines final kotlinx.coroutines.DisposeOnCancel extends kotlinx.coroutines.CancelHandler { private final kotlinx.coroutines.DisposableHandle
6 package kotlinx.coroutines.guide.test8 import kotlinx.coroutines.knit.*14 test("ExampleFlow01") { kotlinx.coroutines.guide.exampleFlow01.main() }.verifyLines( in testExampleFlow01()23 test("ExampleFlow02") { kotlinx.coroutines.guide.exampleFlow02.main() }.verifyLines( in testExampleFlow02()32 test("ExampleFlow03") { kotlinx.coroutines.guide.exampleFlow03.main() }.verifyLines( in testExampleFlow03()41 test("ExampleFlow04") { kotlinx.coroutines.guide.exampleFlow04.main() }.verifyLines( in testExampleFlow04()53 test("ExampleFlow05") { kotlinx.coroutines.guide.exampleFlow05.main() }.verifyLines( in testExampleFlow05()70 test("ExampleFlow06") { kotlinx.coroutines.guide.exampleFlow06.main() }.verifyLines( in testExampleFlow06()81 test("ExampleFlow07") { kotlinx.coroutines.guide.exampleFlow07.main() }.verifyLines( in testExampleFlow07()90 test("ExampleFlow08") { kotlinx.coroutines.guide.exampleFlow08.main() }.verifyLines( in testExampleFlow08()[all …]
1 public final class kotlinx/coroutines/reactor/ConvertKt {2 …public static final fun asFlux (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/Cor…3 …lic static synthetic fun asFlux$default (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/corou…4 …public static final fun asMono (Lkotlinx/coroutines/Deferred;Lkotlin/coroutines/CoroutineContext;)…5 …public static final fun asMono (Lkotlinx/coroutines/Job;Lkotlin/coroutines/CoroutineContext;)Lreac…8 public final class kotlinx/coroutines/reactor/FlowKt {9 public static final fun asFlux (Lkotlinx/coroutines/flow/Flow;)Lreactor/core/publisher/Flux;12 public final class kotlinx/coroutines/reactor/FluxKt {13 …public static final fun flux (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;…14 …public static final fun flux (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineConte…[all …]
1 # Module kotlinx-coroutines-reactive9 | [kotlinx.coroutines.reactive.publish] | `Publisher` | [ProducerScope] | C…18 If these adapters are used along with `kotlinx-coroutines-reactor` in the classpath, then Reactor's…32 <!--- MODULE kotlinx-coroutines-core -->33 <!--- INDEX kotlinx.coroutines -->34 <!--- INDEX kotlinx.coroutines.flow -->35 [Flow]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.flow…36 <!--- INDEX kotlinx.coroutines.channels -->37 [ProducerScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corout…38 <!--- MODULE kotlinx-coroutines-reactive -->[all …]
1 public final class kotlinx/coroutines/rx3/RxAwaitKt {2 …public static final fun await (Lio/reactivex/rxjava3/core/CompletableSource;Lkotlin/coroutines/Con…3 …public static final fun await (Lio/reactivex/rxjava3/core/MaybeSource;Lkotlin/coroutines/Continuat…4 …public static final fun await (Lio/reactivex/rxjava3/core/SingleSource;Lkotlin/coroutines/Continua…5 …public static final fun awaitFirst (Lio/reactivex/rxjava3/core/ObservableSource;Lkotlin/coroutines…6 …(Lio/reactivex/rxjava3/core/ObservableSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Lj…7 …/rxjava3/core/ObservableSource;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Lj…8 … awaitFirstOrNull (Lio/reactivex/rxjava3/core/ObservableSource;Lkotlin/coroutines/Continuation;)Lj…9 …public static final fun awaitLast (Lio/reactivex/rxjava3/core/ObservableSource;Lkotlin/coroutines/…10 …ault (Lio/reactivex/rxjava3/core/MaybeSource;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Lj…[all …]
1 public final class kotlinx/coroutines/reactive/AwaitKt {2 …public static final fun awaitFirst (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuation…3 …rstOrDefault (Lorg/reactivestreams/Publisher;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Lj…4 …Lorg/reactivestreams/Publisher;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Lj…5 …public static final fun awaitFirstOrNull (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Contin…6 …public static final fun awaitLast (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuation;…7 …public static final fun awaitSingle (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Continuatio…8 …gleOrDefault (Lorg/reactivestreams/Publisher;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Lj…9 …Lorg/reactivestreams/Publisher;Lkotlin/jvm/functions/Function0;Lkotlin/coroutines/Continuation;)Lj…10 …public static final fun awaitSingleOrNull (Lorg/reactivestreams/Publisher;Lkotlin/coroutines/Conti…[all …]
1 public abstract interface class kotlinx/coroutines/test/DelayController {7 …public abstract fun pauseDispatcher (Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuati…12 public final class kotlinx/coroutines/test/TestBuildersKt {13 …public static final fun runBlockingTest (Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions…14 …public static final fun runBlockingTest (Lkotlinx/coroutines/test/TestCoroutineDispatcher;Lkotlin/…15 …public static final fun runBlockingTest (Lkotlinx/coroutines/test/TestCoroutineScope;Lkotlin/jvm/f…16 …public static synthetic fun runBlockingTest$default (Lkotlin/coroutines/CoroutineContext;Lkotlin/j…19 …lass kotlinx/coroutines/test/TestCoroutineDispatcher : kotlinx/coroutines/CoroutineDispatcher, kot…24 public fun delay (JLkotlin/coroutines/Continuation;)Ljava/lang/Object;25 public fun dispatch (Lkotlin/coroutines/CoroutineContext;Ljava/lang/Runnable;)V[all …]
1 public final class kotlinx/coroutines/debug/CoroutineInfo {2 public final fun getContext ()Lkotlin/coroutines/CoroutineContext;4 public final fun getJob ()Lkotlinx/coroutines/Job;5 public final fun getState ()Lkotlinx/coroutines/debug/State;10 public final class kotlinx/coroutines/debug/CoroutinesBlockHoundIntegration : reactor/blockhound/in…15 public final class kotlinx/coroutines/debug/DebugProbes {16 public static final field INSTANCE Lkotlinx/coroutines/debug/DebugProbes;18 …public static synthetic fun dumpCoroutines$default (Lkotlinx/coroutines/debug/DebugProbes;Ljava/io…24 public final fun jobToString (Lkotlinx/coroutines/Job;)Ljava/lang/String;25 public final fun printJob (Lkotlinx/coroutines/Job;Ljava/io/PrintStream;)V[all …]
1 public final class kotlinx/coroutines/future/FutureKt {2 …public static final fun asCompletableFuture (Lkotlinx/coroutines/Deferred;)Ljava/util/concurrent/C…3 …public static final fun asCompletableFuture (Lkotlinx/coroutines/Job;)Ljava/util/concurrent/Comple…4 …public static final fun asDeferred (Ljava/util/concurrent/CompletionStage;)Lkotlinx/coroutines/Def…5 …public static final fun await (Ljava/util/concurrent/CompletionStage;Lkotlin/coroutines/Continuati…6 …c static final fun future (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;…7 …thetic fun future$default (Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;…10 public final class kotlinx/coroutines/stream/StreamKt {11 public static final fun consumeAsFlow (Ljava/util/stream/Stream;)Lkotlinx/coroutines/flow/Flow;14 public final class kotlinx/coroutines/time/TimeKt {[all …]
1 public final class kotlinx/coroutines/javafx/JavaFxConvertKt {2 public static final fun asFlow (Ljavafx/beans/value/ObservableValue;)Lkotlinx/coroutines/flow/Flow;5 …lic abstract class kotlinx/coroutines/javafx/JavaFxDispatcher : kotlinx/coroutines/MainCoroutineDi…6 public fun delay (JLkotlin/coroutines/Continuation;)Ljava/lang/Object;7 public fun dispatch (Lkotlin/coroutines/CoroutineContext;Ljava/lang/Runnable;)V8 …c fun invokeOnTimeout (JLjava/lang/Runnable;Lkotlin/coroutines/CoroutineContext;)Lkotlinx/coroutin…9 public fun scheduleResumeAfterDelay (JLkotlinx/coroutines/CancellableContinuation;)V12 public final class kotlinx/coroutines/javafx/JavaFxDispatcherKt {13 public static final fun awaitPulse (Lkotlin/coroutines/Continuation;)Ljava/lang/Object;14 …public static final fun getJavaFx (Lkotlinx/coroutines/Dispatchers;)Lkotlinx/coroutines/javafx/Jav…
1 # Module kotlinx-coroutines-jdk817 | [Deferred.asCompletableFuture][kotlinx.coroutines.Deferred.asCompletableFuture] | Converts a defe…42 [Asynchronous Programming Styles](https://github.com/Kotlin/KEEP/blob/master/proposals/coroutines.m…48 # Package kotlinx.coroutines.future54 <!--- MODULE kotlinx-coroutines-core -->55 <!--- INDEX kotlinx.coroutines -->56 …CoroutineScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corou…57 [Deferred]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/…58 <!--- MODULE kotlinx-coroutines-jdk8 -->59 <!--- INDEX kotlinx.coroutines.future -->[all …]
1 public final class kotlinx/coroutines/slf4j/MDCContext : kotlin/coroutines/AbstractCoroutineContext…2 public static final field Key Lkotlinx/coroutines/slf4j/MDCContext$Key;7 …public fun get (Lkotlin/coroutines/CoroutineContext$Key;)Lkotlin/coroutines/CoroutineContext$Eleme…9 public fun minusKey (Lkotlin/coroutines/CoroutineContext$Key;)Lkotlin/coroutines/CoroutineContext;10 public fun plus (Lkotlin/coroutines/CoroutineContext;)Lkotlin/coroutines/CoroutineContext;11 public synthetic fun restoreThreadContext (Lkotlin/coroutines/CoroutineContext;Ljava/lang/Object;)V12 public fun restoreThreadContext (Lkotlin/coroutines/CoroutineContext;Ljava/util/Map;)V13 public synthetic fun updateThreadContext (Lkotlin/coroutines/CoroutineContext;)Ljava/lang/Object;14 public fun updateThreadContext (Lkotlin/coroutines/CoroutineContext;)Ljava/util/Map;17 public final class kotlinx/coroutines/slf4j/MDCContext$Key : kotlin/coroutines/CoroutineContext$Key…
1 # Module kotlinx-coroutines-guava16 | [Deferred.asListenableFuture][kotlinx.coroutines.Deferred.asListenableFuture] | Converts a deferr…41 …us Programming Styles](https://github.com/Kotlin/kotlin-coroutines/blob/master/kotlin-coroutines-i…47 # Package kotlinx.coroutines.future51 <!--- MODULE kotlinx-coroutines-core -->52 <!--- INDEX kotlinx.coroutines -->53 …CoroutineScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corou…54 <!--- MODULE kotlinx-coroutines-guava -->55 <!--- INDEX kotlinx.coroutines.guava -->56 …e]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-guava/kotlinx.coroutines.guava/…[all …]
1 # Module kotlinx-coroutines-debug3 Debugging facilities for `kotlinx.coroutines` on JVM.7 This module provides a debug JVM agent that allows to track and trace existing coroutines.9 Call to [DebugProbes.install] installs debug agent via ByteBuddy and starts spying on coroutines wh…11 …DebugProbes.dumpCoroutines] to print all active (suspended or running) coroutines, including their…13 Additionally, it is possible to process the list of such coroutines via [DebugProbes.dumpCoroutines…14 of coroutines hierarchy referenced by a [Job] or [CoroutineScope] instances using [DebugProbes.pri…23 Add `kotlinx-coroutines-debug` to your project test dependencies:26 testImplementation 'org.jetbrains.kotlinx:kotlinx-coroutines-debug:1.4.0'33 and to dump coroutines on timeout to simplify tests debugging.[all …]