File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
kotlinx-coroutines-rx/src/main/kotlin Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -16,15 +16,15 @@ import rx.subjects.AsyncSubject
16
16
* @return Observable with single value containing expression returned from coroutine
17
17
*/
18
18
fun <T > asyncRx (
19
- coroutine c : Controller <T >.() -> Continuation <Unit >
19
+ coroutine c : RxController <T >.() -> Continuation <Unit >
20
20
): Observable <T > {
21
- val controller = Controller <T >()
21
+ val controller = RxController <T >()
22
22
c(controller).resume(Unit )
23
23
24
24
return controller.result
25
25
}
26
26
27
- class Controller <T > internal constructor() {
27
+ class RxController <T > internal constructor() {
28
28
internal val result: AsyncSubject <T > = AsyncSubject .create<T >()
29
29
30
30
suspend fun <V > Observable<V>.awaitFirst (x : Continuation <V >) {
You can’t perform that action at this time.
0 commit comments