JakeWharton/RxRelay

Health v2 · maintenance only

Flags: no_releases

Adoption not part of the score

2451 stars · 126 forks observed · 2026-08-28

What it is AI-extracted, prompt v1, taxonomy v1, 2026-08-30, confidence not recorded

RxRelay provides RxJava types that act as both an Observable and a Consumer, essentially Subjects without terminal events (onComplete/onError). This lets developers bridge non-reactive APIs into Rx streams without risking accidental termination of the stream.

Use cases

• bridge non-Rx APIs into RxJava streams
• replace Subjects to avoid accidental onComplete/onError
• emit events to multiple subscribers without terminal state
• buffer and replay events to late subscribers
• build event buses in Android apps with RxJava

When to choose

• you use RxJava and need a stateless-safe Subject alternative
• you want to adapt callback-based APIs into reactive streams
• you need Publish/Behavior/Replay semantics without terminal events

When to avoid

• your project no longer uses RxJava (e.g., migrated to Kotlin coroutines/Flow)
• you need terminal event semantics of Subjects
• you need an AsyncSubject-like behavior, which Relays cannot support

Facets

library · maturity maintenance

concurrency developer-tools developer-tools android-tools jvm rxjava reactive-streams subjects observables event-bus reactive-programming android

Member repositories

For agents

markdown · JSON · MCP: product_card(name="JakeWharton/RxRelay")