Rx class - rxstream library

Constructors

done → Future: A future which is completed when the stream controller is done sending events.
no setteroverride
hasError → bool: no setter
hashCode → int: The hash code for this object.
no setterinherited
hasListener → bool: Whether there is a subscriber on the Stream.
no setteroverride
isClosed → bool: Whether the stream controller is closed for adding more events.
no setteroverride
isPaused → bool: Whether the subscription would need to buffer events.
no setteroverride
onCancel ↔ (FutureOr<void> Function()?): The callback which is called when the stream is canceled.
getter/setter pairoverride
onListen ↔ (void Function()?): The callback which is called when the stream is listened to.
getter/setter pairoverride
onPause ↔ (void Function()?): The callback which is called when the stream is paused.
getter/setter pairoverride
onResume ↔ (void Function()?): The callback which is called when the stream is resumed.
getter/setter pairoverride
runtimeType → Type: A representation of the runtime type of the object.
no setterinherited
sink → StreamSink<T>: Returns a view of this object that only exposes the StreamSink interface.
no setteroverride
stream → Stream<T>: The stream that this controller is controlling.
no setteroverride
value → T?: no setter

add(T event) → void: Sends a data event.
override
addError(Object error, [StackTrace? stackTrace]) → void: Sends or enqueues an error event.
override
addStream(Stream<T> source, {bool? cancelOnError}) → Future: Receives events from source and puts them into this controller's stream.
override
close() → Future: Closes the stream.
override
map<R>(R convert(T event)) → Stream<R>
noSuchMethod(Invocation invocation) → dynamic: Invoked when a nonexistent method or property is accessed.
inherited
toString() → String: A string representation of this object.
inherited