How do you use rx with coroutines? All libs are pr...

# rx

[dave08]

How do you use rx with coroutines? All libs are proof of concept for now,...?

[bamdmux]

Ok, i think theres a misunderstanding here

[bamdmux]

Sequences, coroutines and rx are three different things

[bamdmux]

A sequence is a lazy collection which provides an iterator to get values

[bamdmux]

You dont need coroutines for that if you are working with simple sequential generators

[bamdmux]

But if your generator is complicated you could use coroutines for leveraging that generation

[bamdmux]

and then use the sequence operators like in a simple one, like take(10) or filter or whatever

[bamdmux]

You can use just a Sequence for one thing, a coroutine for other and maybe both for another user case

[bamdmux]

Same with RxJava which is an implementation of the reactive streams

[bamdmux]

You can use RxJava by itself

[bamdmux]

But if you want you can use it along coroutines https://github.com/Kotlin/kotlinx.coroutines/blob/master/reactive/kotlinx-coroutines-rx2/README.md

[bamdmux]

One example of use of both, in a cli utility i have, is I have an observable chain which i await for completion inside a coroutine

[bamdmux]

Another totally different thing is what was dicussed earlier in the thread was the possibility of a rewrite of rxjava or the creation of another reactive streams implementations using coroutines as an underlying tech

[bamdmux]

Thats what only exists as a proof of concept, as @thomasnield said

[dave08]

Yeah but one of the great things about rx is that you can await for results of different parts of the chain and combine the results, which is sequences on steriods... if coroutines are so cheap, why not implement sequences like that from the beginning...?

[dave08]

Its not just awaiting for the result of the whole operation...

[dave08]

Is there such a thing as a production ready rx scheduler to do such at thing?

[bamdmux]

You dont always use sequences to map them to async operations 🙂

[bamdmux]

Coroutines are experimental, but im sure more utilities will come to the stdlib along with the generators

[bamdmux]

For cases like that one

[bamdmux]

And although RxJava is not "coroutine based" id say its pretty production ready

[dave08]

I know rxjava is production ready, im currently using it alot, i was wondering if there is a scheduleOn(RxKotlin.coroutine()) that could be used in production. Or maybe this is impossible?

[bamdmux]

No like that, you could create a coroutine and choose the context you want and then convert it to a flowable with the module i linked earlier

[bamdmux]

But as I said, coroutines are experimental, dont think thats what youd call production ready

[bamdmux]

https://github.com/Kotlin/kotlinx.coroutines/blob/master/reactive/coroutines-guide-reactive.md#coroutine-context

[bamdmux]

Thats the section of contexts of the module guide

[dave08]

Oh! Thanks for the info, Ill look into it.. I thought that 1.1.4 already brought them out from experimental, they were already there from 1.0 i think.. are they putting them out of experimental state soon? I guess thats why everybodys still just at proof of concept discussions on this... 😧

[bamdmux]

The proof of concept is for building rx on top of coroutines not for coroutines per se

[bamdmux]

Regarding as when its out of experimental, i have no idea 🙂 "When its ready".toDateTime() probably