Cysharp/R3
R3
R3 is a reactive extensions library and asynchronous data pipeline framework. It provides a system for composing asynchronous data streams, managing reactive state, and coordinating event sequences using observable patterns.
The project distinguishes itself with a deterministic testing toolkit that mocks time and frame updates to ensure reproducible unit tests for asynchronous logic. It also includes observability tools for tracking active subscriptions and generating stack traces to identify memory leaks, alongside centralized exception routing for pipeline recovery.
The framework covers a broad surface of reactive capabilities, including stream composition, pipeline transformations, and thread-aware scheduling. It provides utilities to convert standard events, property changes, and game engine signals into unified reactive streams, and includes data binding logic to link reactive properties to command execution.
Features
- Observable Streams - Provides core architectural patterns for modeling and composing asynchronous, push-based observable data streams.
- Reactive Stream Architectures - Provides an architectural framework for composing and transforming asynchronous event sequences into data pipelines.
- Reactive Programming - Provides a comprehensive toolkit for building asynchronous data pipelines using reactive programming patterns.
- Event-to-Stream Conversions - Transforms standard event triggers into reactive streams to compose them with other asynchronous data sequences.
- Game Engine Event Streams - Converts engine-specific triggers, physics loops, and frame updates into reactive data streams for game logic coordination.
- Deterministic Time Simulation - Simulates time passage and frame updates with mock providers to ensure deterministic testing of asynchronous logic.
- Reactive Extensions - Implements a library for composing asynchronous and event-based programs using observable sequences.
- Deterministic Testing Toolkits - Ships a toolkit for mocking time and frames to perform reproducible unit tests on asynchronous logic.
- Data Transformation Pipelines - Implements linear sequences of pure functions to transform, filter, and combine asynchronous event sequences.
- Property-to-Stream Conversions - Turns property change notifications into reactive streams to trigger actions whenever model state changes.
- Async Data Pipeline Frameworks - Provides a framework for transforming, filtering and coordinating streams of data across different threading models.
- UI Thread Schedulers - Coordinates the delivery of asynchronous data streams specifically to the main UI thread or engine frames.
- Disposable Observers - Implements a hierarchical disposal pattern to automatically release subscriptions and prevent memory leaks.
- Time and Frame Providers - Decouples time and frame updates through abstract providers to allow deterministic simulation during unit testing.
- Game State Management - Synchronizes game engine frame updates and physics loops with reactive logic to coordinate in-game behavior.
- Task Interoperability - Converts single-value asynchronous operations into tasks to ensure interoperability with standard async-await patterns.
- UI Data Binding - Links reactive properties to command logic to automatically update interface states based on live data changes.
- Event-to-Observable Conversion - Converts standard event triggers and property changes into observables to simplify complex asynchronous workflows.
- Exception Handling Pipelines - Captures unexpected errors in the data pipeline and routes them to a specified handler for logging and recovery.
- Pipeline Exception Routing - Provides centralized exception routing to intercept and recover from unhandled errors within reactive pipelines.
- Reactive State Management - Provides a system for binding properties and events to reactive pipelines to synchronize state and logic.
- Subscription Lifecycle Monitoring - Monitors active data streams and generates stack traces to identify and resolve memory leaks.
- Memory Leak Detection - Tracks active data subscriptions and generates stack traces to identify and resolve memory leaks in event pipelines.
- Virtual Time Testing - Provides testing utilities that decouple event emission and frame updates from the system clock using mock providers.
- UI Framework Synchronization - Synchronizes timing and frame updates with the host user interface thread to prevent rendering glitches.
