rx4u Examples
Comprehensive examples showcasing rx4u's reactive programming capabilities. Learn by example with practical, real-world use cases.
Creating and Subscribing to Streams
BasicsLearn the fundamentals of creating streams and subscribing to them.
Stream CreationSubscriptionCleanup
Transforming Data with map
TransformationTransform stream values using the map operator.
map operatorData transformationType preservation
Filtering Data with Predicates
FilteringFilter stream values based on conditions.
filter operatortake operatorskip operatorPredicate functions
Handling Async Operations
AsyncWork with promises and async data using switchMap.
switchMap operatorPromise handlingAsync transformation
Robust Error Handling
Error HandlingHandle errors gracefully with catchError and retry.
catchError operatorretry operatorError recoveryFallback values
Debouncing User Input
UtilityOptimize user input handling with debounceTime.
debounceTime operatordistinctUntilChanged operatorInput optimizationSearch patterns
Combining Multiple Streams
CombinationCombine data from multiple sources using combineLatest and zip.
combineLatest operatorzip operatorStream combinationData correlation
Reactive State Management
StateManage application state reactively with createState.
createState functionReactive stateDerived stateState management patterns