File tree Expand file tree Collapse file tree 2 files changed +0
-20
lines changed
src/main/kotlin/kotlinx/coroutines/experimental/rx1 Expand file tree Collapse file tree 2 files changed +0
-20
lines changed Original file line number Diff line number Diff line change @@ -14,7 +14,6 @@ Suspending extension functions and suspending iteration:
14
14
15
15
| ** Name** | ** Description**
16
16
| -------- | ---------------
17
- | [ Completable.await] [ rx.Completable.await ] | Awaits for completion of the completable value
18
17
| [ Single.await] [ rx.Single.await ] | Awaits for completion of the single value and returns it
19
18
| [ Observable.awaitFirst] [ rx.Observable.awaitFirst ] | Returns the first value from the given observable
20
19
| [ Observable.awaitLast] [ rx.Observable.awaitFirst ] | Returns the last value from the given observable
@@ -44,7 +43,6 @@ Conversion functions:
44
43
[ rxCompletable ] : https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx1/kotlinx.coroutines.experimental.rx1/rx-completable.html
45
44
[ rxSingle ] : https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx1/kotlinx.coroutines.experimental.rx1/rx-single.html
46
45
[ rxObservable ] : https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx1/kotlinx.coroutines.experimental.rx1/rx-observable.html
47
- [ rx.Completable.await ] : https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx1/kotlinx.coroutines.experimental.rx1/rx.-completable/await.html
48
46
[ rx.Single.await ] : https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx1/kotlinx.coroutines.experimental.rx1/rx.-single/await.html
49
47
[ rx.Observable.awaitFirst ] : https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx1/kotlinx.coroutines.experimental.rx1/rx.-observable/await-first.html
50
48
[ rx.Observable.awaitSingle ] : https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-rx1/kotlinx.coroutines.experimental.rx1/rx.-observable/await-single.html
Original file line number Diff line number Diff line change @@ -22,24 +22,6 @@ import kotlinx.coroutines.experimental.Job
22
22
import kotlinx.coroutines.experimental.suspendCancellableCoroutine
23
23
import rx.*
24
24
25
- // ------------------------ Completable ------------------------
26
-
27
- /* *
28
- * Awaits for completion of the completable value without blocking a thread and
29
- * returns or throws the corresponding exception if this completable had produced error.
30
- *
31
- * This suspending function is cancellable.
32
- * If the [Job] of the current coroutine is completed while this suspending function is waiting, this function
33
- * immediately resumes with [CancellationException].
34
- */
35
- public suspend fun Completable.await (): Unit = suspendCancellableCoroutine { cont ->
36
- subscribe(object : CompletableSubscriber {
37
- override fun onSubscribe (sub : Subscription ) { cont.unsubscribeOnCompletion(sub) }
38
- override fun onCompleted () { cont.resume(Unit ) }
39
- override fun onError (error : Throwable ) { cont.resumeWithException(error) }
40
- })
41
- }
42
-
43
25
// ------------------------ Single ------------------------
44
26
45
27
/* *
You can’t perform that action at this time.
0 commit comments