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.
Hey guys. I have a Flowable<byte>.
It provides raw communication data.
I want to convert these byte-Arrays into "Java Objects".
Unfortunately the byte arrays do not correspond to the beginning/end of each object. I first have to detect the beginning/end of each object.
Any ideas how to solve this with RxJava?