RxRelay
RxJava types that are both an Observable and a Consumer, providing Subjects without terminal events.
What is RxRelay?
RxRelay is an RxJava library that provides Relay types, which are both Observable and Consumer interfaces. It solves the problem of bridging non-reactive APIs into reactive streams without the risk of accidentally triggering terminal states like onComplete or onError, which can render Subjects unusable.
RxJava developers, particularly those working on Android or Java applications, who need to integrate non-reactive APIs or manage event streams without terminal event side effects.
Developers choose RxRelay over standard Subjects because it eliminates the stateful risk of terminal events, ensuring Relays remain usable for continuous data flow, making it safer for transitional or bridge scenarios in reactive programming.
Overview
RxJava types that are both an Observable and a Consumer.
Use Cases
Best For
- Bridging non-reactive APIs into RxJava streams
- Managing event buses without terminal state risks
Found a gem we're missing?
Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.