CustomStream<T extends Event> 类 抽象

自定义事件流，允许用户将自定义事件添加到事件流中。

实现类型

构造函数

CustomStream()

属性

first → Future<T>
此流的第一个元素。
无setter继承
hashCode → int
此对象的哈希码。
无setter继承
isBroadcast → bool
是否此流是广播流。
无setter继承
isEmpty → Future<bool>
是否此流包含任何元素。
无setter继承
last → Future<T>
此流的最后一个元素。
无setter继承
length → Future<int>
此流中元素的数量。
无setter继承
runtimeType → Type
表示对象运行时类型的表现。
无setter继承
single → Future<T>
此流的单个元素。
无setter继承

方法

add(T event) → void
将以下自定义事件添加到流中以供感兴趣的事件监听者分发。
any(bool test(T element)) → Future<bool>
检查是否test接受该流提供的任何元素。
继承
asBroadcastStream({void onListen(StreamSubscription<T> subscription)?, void onCancel(StreamSubscription<T> subscription)?}) → Stream<T>
返回一个多订阅流，它产生与当前相同的210事件。
继承
asyncExpand<E>(Stream<E>? convert(T event)) → Stream<E>
将每个元素转换成一系列异步事件。
继承
asyncMap<E>(FutureOr<E> convert(T event)) → Stream<E>
创建一个新的流，将此流的每个数据事件异步映射为新事件。
继承
cast<R>() → Stream<R>
将此流适配为 Stream<R>。
继承
contains(Object? needle) → Future<bool>
返回 needle 是否出现在此流提供的事件中。
继承
distinct([bool equals(T previous, T next)?]) → Stream<T>
如果事件与上一个事件相同，则跳过数据事件。
继承
drain<E>([E? futureValue]) → Future<E>
丢弃此流上的所有数据，但会信号何时完成或发生错误。
继承
elementAt(int index) → Future<T>
返回此流的第 index 个数据事件的值。
继承
every(bool test(T element)) → Future<bool>
检查 test 是否接受此流提供的所有元素。
继承
expand<S>(Iterable<S> convert(T element)) → Stream<S>
将此流中的每个元素转换为一个元素的序列。
继承
firstWhere(bool test(T element), {T orElse()?}) → Future<T>
查找与此流中匹配 test 的第一个元素。
继承
fold<S>(S initialValue, S combine(S previous, T element)) → Future<S>
通过重复应用 combine 来组合一系列值。
继承
forEach(void action(T element)) → Future<void>
对此流中的每个元素执行 action。
继承
handleError(Function onError, {bool test(dynamic error)?}) → Stream<T>
创建一个流包装器，该包装器拦截从该流中捕获的某些错误。
继承
join([String separator = ""]) → Future<String>
将元素的字符串表示形式组合成一个单字符串。
继承
lastWhere(bool test(T element), {T orElse()?}) → Future<T>
在此流中查找最后一个匹配 test 的元素。
继承
listen(void onData(T event)?, {Function? onError, void onDone()?, bool? cancelOnError}) → StreamSubscription<T>
为此流添加订阅。
继承
map<S>(S convert(T event)) → Stream<S>
将此流的每个元素转换成新的流事件。
继承
noSuchMethod(Invocation invocation) → dynamic
当访问不存在的方法或属性时被调用。
继承
pipe(StreamConsumer<T> streamConsumer) → Future
将此流的事件通过 streamConsumer 导入。
继承
reduce(T combine(T previous, T element)) → Future<T>
通过重复应用 combine 来组合一系列值。
继承
singleWhere(bool test(T element), {T orElse()?}) → Future<T>
查找此流中与 test 匹配的单个元素。
继承
skip(int count) → Stream<T>
跳过此流中前面 count 个数据事件。
继承
skipWhile(bool test(T element)) → Stream<T>
当数据事件匹配 test 时跳过这些事件。
继承
继承
继承
继承
继承
继承
继承
继承
继承

继承