ElementStream<T extends Event>抽象

Element 类可用的专用 Stream,用于启用事件代理。

实现类型

构造函数

ElementStream()

属性

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

方法

any(bool test(T element)) Future<bool>
检查 test 是否接受此 Stream 提供的任何元素。
继承
asBroadcastStream({void onListen(StreamSubscription<T> subscription)?, void onCancel(StreamSubscription<T> subscription)?}) Stream<T>
返回一个支持多订阅的流,它产生与当前流相同的事件。
继承
asyncExpand<E>(Stream<E>? convert(T event)) Stream<E>
将每个元素转换为异步事件序列。
继承
asyncMap<E>(FutureOr<E> convert(T event)) Stream<E>
创建一个新的流,将当前流的每个数据事件异步映射到新事件。
继承
capture(void onData(T event)) StreamSubscription<T>
向此流添加一个捕获订阅。
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>
将流中的每个元素转换成新的流事件。
继承
matches(String selector) Stream<T>
返回一个流,只有当匹配特定CSS选择器的元素触发特定事件时,该流才会触发。
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时跳过此流的数据事件。
继承
take(int count) Stream<T>
提供此流的前最多count个数据事件。
继承
takeWhile(bool test(T element)) Stream<T>
test成功时,继续传递数据事件。
继承
timeout(Duration timeLimit, {void onTimeout(EventSink<T> sink)?}) Stream<T>
创建一个与当前流具有相同事件的新的流。
继承
toList() Future<List<T>>
将此流的全部元素收集到一个List中。
继承
toSet() Future<Set<T>>
将此流的元素收集到一个Set中。
继承
toString() String
此对象的一个字符串表示。
继承
transform<S>(StreamTransformer<T, S> streamTransformer) Stream<S>
streamTransformer应用于此流。
继承
where(bool test(T event)) Stream<T>
从当前流中创建一个新的流,丢弃一些元素。
继承

操作符

operator ==(Object other) bool
等号操作符。
继承