reactive_component library

Supports for creating stream-based reactive components, designed for simplicity, composability, flexibility.

Classes

Reactive<D>

A special kind of StreamController that holds its latest stream data, and sends that as the first data to any new listener.

ReactiveEventSink<T>

A ReactiveSink that implements EventSink.

ReactiveSink<T>

A special kind of Sink with its own single stream listener that handles the event data.

ReactiveStreamSink<T>

A ReactiveSink that implements StreamSink.

VoidReactiveEventSink

A VoidReactiveSink that implements EventSink.

VoidReactiveSink

ReactiveSink of void type.

VoidReactiveStreamSink

A VoidReactiveSink that implements StreamSink.

Mixins

ReactiveComponent

A mixin that represents ReactiveComponent.

ReactiveOutputComponent

ReactiveOutputComponent

ReactiveResource

A mixin that handles resource disposing with only Sink and Stream public interface.

Constants

streamIO → const _StreamIO

The annotation @streamIO marks all public instance members' return type in the class must be a kind of Stream or Sink.

_StreamIO()

streamOutput → const _StreamOutput

The annotation @streamOutput marks all public instance members' return type in the class must be a kind of Stream or FutureOr<void>.

_StreamOutput()

Typedefs

FutureOrVoidCallback = FutureOr<void> Function()

HandleSubscription<T> = void Function(StreamSubscription<T> subscription)

OnData<T> = void Function(T data)

OnError = void Function(Object error, StackTrace stackTrace)

Transform<T> = Stream<T> Function(Stream<T> stream)