rengwuxian/RxJavaSamples
RxJavaSamples
RxJavaSamples is a collection of reference implementations and practical guides for applying reactive patterns to asynchronous networking and state management. It provides code demonstrations for integrating reactive streams with Retrofit to handle network requests in a non-blocking manner.
The project focuses on asynchronous patterns for managing API calls, including the combination of concurrent streams and the use of subjects to cache emitted values for state management. It specifically demonstrates how to implement automated token refresh workflows to maintain authenticated sessions without interrupting the user.
The repository covers broader capabilities in request orchestration, such as sequencing dependent network calls and aggregating multiple parallel requests into single response objects. It also includes implementations for response data formatting and adapter-based mapping of API responses into structured Java objects.
Features
- Reactive Networking - Provides a comprehensive implementation of non-blocking network programming using RxJava and Retrofit.
- RxJava Android Guides - Offers practical guides and examples for integrating RxJava reactive streams with Retrofit.
- Automatic Token Refreshes - Automatically refreshes expired authentication tokens by intercepting network responses and retrying calls.
- Observable Streams - Processes asynchronous network events as observable data streams for real-time updates.
- Asynchronous Patterns - Implements asynchronous patterns using RxJava for stream combination and state management.
- Implementation Samples - Provides practical code demonstrations for managing asynchronous API calls and request orchestration.
- Request Chaining - Implements the chaining of dependent network calls where one response informs the next request.
- Parallel Request Executions - Provides mechanisms to execute multiple network requests concurrently to reduce total wait time.
- Parallel Data Fetching - Executes multiple API requests simultaneously and merges results into a single data stream.
- Last Value Caching - Implements last-value caching to provide new subscribers with the most recent state of a stream.
- Reactive Stream Caching - Uses BehaviorSubjects to cache the latest emitted value for immediate state recovery.
- Asynchronous Operation Chaining - Sequences dependent network calls by piping the output of one reactive request into the input of another.
- Concurrent Aggregators - Combines multiple concurrent network requests into a single response object using zip operators.
- Response Formatting - Converts raw API response data into structured formats for easier processing by observers.
- Response Type Mapping - Converts raw API responses into structured Java objects using reactive transformation operators.
Star history
How this analysis was created: This summary and feature list are AI-generated from collected project material and can contain mistakes. Stars, license and language are imported from GitHub. Inclusion does not mean that we have tested or audited this project. Check the source documentation for any feature you depend on. Learn more on our About page.
