RxTransformations<T> extension

Transformation extensions for reactive values

on

• Rx<T>

Methods

asNullable() → RxComputed<T?>

Available on Rx<T>, provided by the RxTransformations extension

Convert to nullable type

combineLatest<U, R>(Rx<U> other, R combiner(T, U)) → RxComputed<R>

Available on Rx<T>, provided by the RxTransformations extension

Combine with another reactive value

distinctMap<R>(R mapper(T)) → RxComputed<R>

Available on Rx<T>, provided by the RxTransformations extension

Create a reactive value that only updates when the mapped value changes

filter(bool predicate(T)) → RxComputed<T?>

Available on Rx<T>, provided by the RxTransformations extension

Filter values based on a predicate

skip(int count) → RxComputed<T?>

Available on Rx<T>, provided by the RxTransformations extension

Skip the first n values, returns null until exhausted. Always accesses value so dependency tracking is maintained, fixing a bug where the computed became permanently dead during the skip phase (since it never accessed value and thus tracked no dependencies).

switchMap<R>(RxComputed<R> mapper(T)) → RxComputed<R>

Available on Rx<T>, provided by the RxTransformations extension

Switch to a new reactive value based on current value

take(int count) → RxComputed<T?>

Available on Rx<T>, provided by the RxTransformations extension

Take the first n values, returns null once exhausted. Always accesses value so dependency tracking is maintained, ensuring re-evaluation when the source changes.

transform<R>(R mapper(T)) → RxComputed<R>

Available on Rx<T>, provided by the RxTransformations extension

Transform this reactive value to another type