Repeater<T> class

Repeater sets an underlying stream up on the first subscription to the output stream and shuts it down when there are no more subscriptions.

The underlying stream can be manually shut down by calling detach and set up again by calling attach without terminating the existing subscriptions to the output stream.

Constructors

Repeater({required Stream<T> onListenEmitFrom(), Future onCancel()?, bool isSync = false})
Repeater.broadcast({required Stream<T> onListenEmitFrom(), Future onCancel()?, bool isSync = false})
Repeater.fromStream(Stream<T> source, {Future onCancel()?, bool isSync = false})
factory

Properties

detachCount ↔ int
getter/setter pair
hashCode → int
The hash code for this object.
no setterinherited
log ↔ void Function(String)
getter/setter pair
runtimeType → Type
A representation of the runtime type of the object.
no setterinherited
stream → Stream<T>
The output stream.
no setter

Methods

attach() → void
Resumes forwarding events from the source stream.
detach() → Future<void>
Stops forwarding events from the source stream.
dispose() → Future<Unit>
Closes the stream.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
toString() → String
A string representation of this object.
inherited

Operators

operator ==(Object other) → bool
The equality operator.
inherited