rengwuxian/RxJavaSamples
RxJavaSamples
RxJavaSamples 是一个参考实现和实践指南集合，用于将响应式模式应用于异步网络和状态管理。它提供了将响应式流与 Retrofit 集成的代码演示，以非阻塞方式处理网络请求。
该项目专注于管理 API 调用的异步模式，包括组合并发流以及使用 Subject 缓存发射的值以进行状态管理。它特别演示了如何实现自动化令牌刷新工作流，以在不中断用户的情况下维护已认证的会话。
该仓库涵盖了请求编排中更广泛的功能，例如对依赖网络调用进行排序，以及将多个并行请求聚合为单个响应对象。它还包括用于响应数据格式化和将 API 响应适配映射为结构化 Java 对象的实现。
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.
