ElementStream<T extends Event> 类 抽象

Element 元素可用的专用 Stream，用于启用事件委托。

实现类型

构造函数

ElementStream()

属性

first → Future<T>
该 Stream 的第一个元素。
无设置器继承
hashCode → int
该对象的哈希码。
无设置器继承
isBroadcast → bool
该 Stream 是否为广播 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>
检查测试函数是否接受此 Stream 提供的任何元素。
继承
asBroadcastStream({void onListen(StreamSubscription<T> subscription)?, void onCancel(StreamSubscription<T> subscription)?}) → Stream<T>
返回一个可以产生与该 Stream 相同事件的多个订阅的 Stream。
继承
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[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
等于运算符。
继承