Raxol.UI.State.Streams (Raxol v2.0.1)

Reactive streams system for real-time data flow in Raxol UI.

Refactored version with pure functional error handling patterns. All try/catch blocks have been replaced with with statements and proper error tuples.

This module provides RxJS-like reactive programming capabilities with:

Observable streams of data
Operators for transforming data (map, filter, reduce, etc.)
Hot and cold observables
Backpressure handling
Functional error handling and retry strategies
Subscription management
Combining multiple streams

Summary

Functions

cancel_existing_timer(timer)

combine_latest(observables)

Combines latest values from multiple streams.

debounce(observable, milliseconds)

Debounces values, only emitting after a period of silence.

emit_debounced_value(value, observer)

filter(observable, predicate_fn)

Filters values in the stream based on a predicate.

from_events(event_type)

Creates an observable from UI events.

from_list(list)

Creates an observable from a list of values.

from_range(range)

Creates an observable from a range of numbers.

from_store_path(path, store \\ Store)

Creates an observable from Store state changes.

interval(milliseconds, value_fn \\ fn i -> i end)

Creates an observable that emits values at regular intervals.

map(observable, mapper_fn)

Transforms values in the stream using a mapping function.

reduce(observable, initial, reducer_fn)

Reduces values in the stream to a single value.

skip(observable, count)

Skips the first N values from the stream.

subscribe(observable, observer_or_fn)

Subscribes to an observable with an observer or simple next function.

take(observable, count)

Takes only the first N values from the stream.

timer(milliseconds, value)

Creates an observable that emits a single value after a delay.

unsubscribe(subscription)

Unsubscribes from an observable.