CustomStream<T extends Event> classabstract
A stream of custom events, which enables the user to "fire" (add) their owncustom events to a stream.
- Implemented types
- Stream<
T>
- Stream<
Constructors
Properties
- first→Future<
T> - The first element of this stream.no setterinherited
- hashCode→int
- The hash code for this object.no setterinherited
- isBroadcast→bool
- Whether this stream is a broadcast stream.no setterinherited
- isEmpty→Future<
bool> - Whether this stream contains any elements.no setterinherited
- last→Future<
T> - The last element of this stream.no setterinherited
- length→Future<
int> - The number of elements in this stream.no setterinherited
- runtimeType→Type
- A representation of the runtime type of the object.no setterinherited
- single→Future<
T> - The single element of this stream.no setterinherited
Methods
- add(
Tevent)→ void - Add the following custom event to the stream for dispatching to interestedlisteners.
- any(
booltest(Telement))→Future< bool> - Checks whether
testaccepts any element provided by this stream.inherited - asBroadcastStream(
{voidonListen(StreamSubscription< T> subscription)?,voidonCancel(StreamSubscription<T> subscription)?})→Stream<T> - Returns a multi-subscription stream that produces the same events as this.inherited
- asyncExpand<
E> (Stream< E> ?convert(Tevent))→Stream<E> - Transforms each element into a sequence of asynchronous events.inherited
- asyncMap<
E> (FutureOr< E> convert(Tevent))→Stream<E> - Creates a new stream with each data event of this stream asynchronouslymapped to a new event.inherited
- cast<
R> ()→Stream< R> - Adapt this stream to be a
Stream<R>.inherited - contains(
Object?needle)→Future< bool> - Returns whether
needleoccurs in the elements provided by this stream.inherited - distinct(
[boolequals(Tprevious,Tnext)?])→Stream< T> - Skips data events if they are equal to the previous data event.inherited
- drain<
E> ([E?futureValue])→Future< E> - Discards all data on this stream, but signals when it is done or an erroroccurred.inherited
- elementAt(
intindex)→Future< T> - Returns the value of the
indexth data event of this stream.inherited - every(
booltest(Telement))→Future< bool> - Checks whether
testaccepts all elements provided by this stream.inherited - expand<
S> (Iterable< S> convert(Telement))→Stream<S> - Transforms each element of this stream into a sequence of elements.inherited
- firstWhere(
booltest(Telement), {TorElse()?})→Future< T> - Finds the first element of this stream matching
test.inherited - fold<
S> (SinitialValue,Scombine(Sprevious,Telement))→Future< S> - Combines a sequence of values by repeatedly applying
combine.inherited - forEach(
voidaction(Telement))→Future< void> - Executes
actionon each element of this stream.inherited - handleError(
FunctiononError, {booltest(dynamicerror)?})→Stream< T> - Creates a wrapper Stream that intercepts some errors from this stream.inherited
- join(
[Stringseparator =""])→Future< String> - Combines the string representation of elements into a single string.inherited
- lastWhere(
booltest(Telement), {TorElse()?})→Future< T> - Finds the last element in this stream matching
test.inherited - listen(
voidonData(Tevent)?, {Function?onError,voidonDone()?,bool?cancelOnError})→StreamSubscription< T> - Adds a subscription to this stream.inherited
- map<
S> (Sconvert(Tevent))→Stream< S> - Transforms each element of this stream into a new stream event.inherited
- noSuchMethod(
Invocationinvocation)→ dynamic - Invoked when a nonexistent method or property is accessed.inherited
- pipe(
StreamConsumer< T> streamConsumer)→Future - Pipes the events of this stream into
streamConsumer.inherited - reduce(
Tcombine(Tprevious,Telement))→Future< T> - Combines a sequence of values by repeatedly applying
combine.inherited - singleWhere(
booltest(Telement), {TorElse()?})→Future< T> - Finds the single element in this stream matching
test.inherited - skip(
intcount)→Stream< T> - Skips the first
countdata events from this stream.inherited - skipWhile(
booltest(Telement))→Stream< T> - Skip data events from this stream while they are matched by
test.inherited - take(
intcount)→Stream< T> - Provides at most the first
countdata events of this stream.inherited - takeWhile(
booltest(Telement))→Stream< T> - Forwards data events while
testis successful.inherited - timeout(
DurationtimeLimit, {voidonTimeout(EventSink< T> sink)?})→Stream<T> - Creates a new stream with the same events as this stream.inherited
- toList(
)→Future< List< T> > - Collects all elements of this stream in aList.inherited
- toSet(
)→Future< Set< T> > - Collects the data of this stream in aSet.inherited
- toString(
)→String - A string representation of this object.inherited
- transform<
S> (StreamTransformer< T,S> streamTransformer)→Stream<S> - Applies
streamTransformerto this stream.inherited - where(
booltest(Tevent))→Stream< T> - Creates a new stream from this stream that discards some elements.inherited
Operators
- operator ==(
Objectother)→bool - The equality operator.inherited