Is there a library to provide extension functions ...

# coroutines

[javad]

Is there a library to provide extension functions for RxJava 1 types? Like Single.await()? The official lib only supports RxJava 2 😞

[Jonathan]

No support has been droped

[Jonathan]

RxJava 1 is discontinued for quite a wile already

[Jonathan]

But it is easy to implement your own

[javad]

do you mind explaining more about implementing one?

[javad]

or giving some hints

[Jonathan]

You can use suspendCoroutine
Here's an example:

suspend fun <T> Single<T>.await(): T = supendCancellableCoroutine { cont ->
	val disposable = subscribe(
		{ cont.resume(it) }, // onSuccess
		{ cont.resumeWithException(it) } // onError
	)
	
	cont.invokeOnCancellation {
		disposable.dispose()
	}
}

[Jonathan]

My example is only on conceptual level, and probably doesn't compile

[javad]

thank you very much! appreciate it 🙂

[Jonathan]

Actually my exmple would work with RxJava 2 (I just tried)

[Jonathan]

So you only have to adapt to the RxJava1 API, which I don't know well.

[Zach Klippenstein (he/him) [MOD]]

The Rx2 adapter library actually does a lot of work to manage backpressure etc, you might want to consider just using that library with the Rx1/Rx2 adapter library from David Karnok

[gildor]

You can copy old (dropped) implementation of Rx1 adapter to you project