RxReplayingShare
An RxJava transformer that combines replay(1), publish(), and refCount() operators for efficient value caching.
What is RxReplayingShare?
ReplayingShare is an RxJava transformer that combines replay(1), publish(), and refCount() operators into a single optimized operator. It solves the problem of efficiently sharing expensive observable streams by caching the last emitted value only when subscribers are present and automatically disconnecting from upstream when no one is listening.
RxJava developers working with expensive or long-lived observable streams who need to share them across multiple subscribers while managing resource consumption.
Developers choose ReplayingShare because it provides the ideal combination of value replay and resource management in a single operator, eliminating the need to manually compose multiple operators and avoiding the pitfalls of traditional combinations.
Overview
An RxJava transformer which combines replay(1), publish(), and refCount() operators.
Use Cases
Best For
- Sharing expensive data transformation streams across multiple subscribers
Related Projects
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.
