These are chat archives for ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
Hi, Guys, yet another newbie question.
So I want to write a Http Server based on RxJS2, but I’m stuck with plain old Strings manipulation.
So, for instanse, I’ve got an
Observable<String> which is being terminated with a ‘\r\n’ sequence.
I want to get from
‘123\r\n12’ ‘3\r\n123\r\nab’ ‘c\r\n\r\n’
something like this
‘123’ ‘123’ ‘abc’ ‘’
I think I should use a Subject to store some state but I don’t know really how it could be done.
source.flatMap(string -> Rx.Observable.from(string.split()))