Simple Relay RxBus with similar api to Event Bus
The Bus makes use of PublishRelay provided by RxRelay.
Register to all events in class
- Event class
class ConsumerEvent
- Observe to event types
RxBus.observe(ConsumerEvent.class)
.subscribe(event -> {})
Event will be received on both sticky and non sticky events.
- Post events
RxBus.post(new MyEvent())
RxBus.postSticky(new MyEvent())