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 folks, I am just starting out with RxJava and am trying to implement it as an event bus.
Is is very bad practice to pass Cancellable events through the bus (these events are mutable, and after being processed the behaviour is result or not)?
If it's ok how can I subscribe with a priority in the call iteration?
I would really appreciate any help that can be given! Thanks guys!