AxiomStreamExtensions<T> extension
- on
-
- Stream<
AxiomState< T> >
- Stream<
Methods
-
onData(
void callback(T data)) → Stream< AxiomState< T> > -
Available on Stream<
Side effect: Execute callback when data arrives (cache or network).AxiomState< , provided by the AxiomStreamExtensions extensionT> > -
onlyData(
) → Stream< T> -
Available on Stream<
Filters the stream to only emit data events.AxiomState< , provided by the AxiomStreamExtensions extensionT> > -
unwrap(
) → Future< T> -
Available on Stream<
Returns a Future that completes with the first valid data received. Useful for "awaiting" a stream result like a standard API call. Throws if the stream ends or errors without data.AxiomState< , provided by the AxiomStreamExtensions extensionT> >