Searched refs:completable (Results 1 – 8 of 8) sorted by relevance
18 val completable = rxCompletable(currentDispatcher()) { in <lambda>() constant22 completable.subscribe { in <lambda>()33 val completable = rxCompletable(currentDispatcher()) { in <lambda>() constant38 completable.subscribe({ in <lambda>()53 val completable = rxCompletable(currentDispatcher()) { in <lambda>() constant60 val sub = completable.subscribe({ in <lambda>()76 val completable = rxCompletable(currentDispatcher()) { in <lambda>() constant80 completable.await() // shall launch coroutine in <lambda>()87 val completable = rxCompletable(currentDispatcher()) { in <lambda>() constant93 completable.await() // shall launch coroutine and throw exception in <lambda>()[all …]
21 val completable = job.asCompletable(coroutineContext.minusKey(Job)) in <lambda>() constant22 completable.subscribe { in <lambda>()37 val completable = job.asCompletable(coroutineContext.minusKey(Job)) in <lambda>() constant38 completable.subscribe { in <lambda>()
48 val completable = CompletableFuture<String>() in <lambda>() constant49 completable.complete("O") in <lambda>()50 val toAwait: CompletionStage<String> = completable in <lambda>()70 val completable = CompletableFuture<String>() in <lambda>() constant71 val toAwait: CompletionStage<String> = completable in <lambda>()76 completable.complete("O") in <lambda>()97 val completable = CompletableFuture<String>() in <lambda>() constant98 val toAwait: CompletionStage<String> = completable in <lambda>()99 completable.completeExceptionally(TestException("O")) in <lambda>()134 val completable = CompletableFuture<String>() in <lambda>() constant[all …]
9 | [rxCompletable] | `Completable` | [CoroutineScope] | Cold completable t…27 …o.reactivex.rxjava3.core.CompletableSource.await] | Awaits for completion of the completable value 46 | [Job.asCompletable][kotlinx.coroutines.Job.asCompletable] | Converts job to hot completable60 …tlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/rx-completable.html68 …tlinx-coroutines-rx3/kotlinx.coroutines.rx3/io.reactivex.rxjava3.core.-completable-source/await.ht…77 …oroutines/kotlinx-coroutines-rx3/kotlinx.coroutines.rx3/kotlinx.coroutines.-job/as-completable.html
9 | [rxCompletable] | `Completable` | [CoroutineScope] | Cold completable t…27 …urce.await][io.reactivex.CompletableSource.await] | Awaits for completion of the completable value 48 | [Job.asCompletable][kotlinx.coroutines.Job.asCompletable] | Converts job to hot completable64 …tlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/rx-completable.html72 …coroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/io.reactivex.-completable-source/await.ht…83 …oroutines/kotlinx-coroutines-rx2/kotlinx.coroutines.rx2/kotlinx.coroutines.-job/as-completable.html
63 …x-coroutines-jdk8/kotlinx.coroutines.future/kotlinx.coroutines.-deferred/as-completable-future.html