ReadPipe 类 抽象 接口

由 Pipe 创建的 "read" 端。

读取流将继续监听，直到管道的 "write" 端（即 Pipe.write）被关闭。

final pipe = await Pipe.create();
pipe.read.transform(utf8.decoder).listen((data) {
  print(data);
}, onDone: () => print('Done'));
实现类型

构造函数

ReadPipe()

属性

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

方法

any(bool test(List<int> element)) → Future<bool>
检查 test 是否接受由此流提供的任何元素。
继承
asBroadcastStream({void onListen(StreamSubscription<List<int>><List<int>><int> subscription)?, void onCancel(StreamSubscription<List<int>> subscription)?}) → Stream<List<int>>
返回一个多订阅流，它会产生与这个流相同的事件。
继承
asyncExpand<E>(Stream<E><E>? convert(List<int> event)) → Stream<E>
将每个元素转换为异步事件序列。
继承
asyncMap<E>(FutureOr<E> convert(List<int> event)) → Stream<E>
创建一个新的流，其中每个数据事件都以异步方式映射到新的事件。
继承
cast<R>() → Stream<R>
将此流适配为 Stream<R>。
继承
contains(Object? needle) → Future<bool>
返回是否发生 needle 出现在此流提供的元素中。
继承
distinct([bool equals(List<int> previous, List<int> next)?]) → Stream<List<int>>
跳过与上一个数据事件相等的数据事件。
继承
drain<E>([E? futureValue]) → Future<E>
丢弃此流的全部数据，但信号已完成或发生了错误。
继承
elementAt(int index) → Future<List<int>>
返回此流的第 index 个数据事件的值。
继承
every(bool test(List<int> element)) → Future<bool>
检查 test 是否接受由该流提供的所有元素。
继承
expand<S>(Iterable<S> convert(List<int> element)) → Stream<S>
将此流的每个元素转换成一系列元素。
继承
firstWhere(bool test(List<int> element), {List<int> orElse()?}) → Future<List<int>>
查找匹配 test 的第一个元素。
继承
fold<S>(S initialValue, S combine(S previous, List<int> element)) → Future<S>
通过反复应用 combine 函数来组合一个值序列。
继承
forEach(void action(List<int> element)) → Future<void>
对当前流中的每个元素执行 action 操作。
继承
handleError(Function onError, {bool test(dynamic error)?}) → Stream<List<int>>
创建一个包装流，拦截来自当前流的某些错误。
继承
join([String separator = ""]) → Future<String>
将元素的字符串表示形式组合成一个单个字符串。
继承
lastWhere(bool test(List<int> element), {List<int> orElse()?}) → Future<List<int>>
寻找与 test 匹配的最后一个元素。
继承
listen(void onData(List<int> event)?, {Function? onError, void onDone()?, bool? cancelOnError}) → StreamSubscription<List<int>>
为此流添加订阅。
继承
map<S>(S convert(List<int> event)) → Stream<S>
将此流的每个元素转换为新的流事件。
继承
noSuchMethod(Invocation invocation) → dynamic
当访问不存在的方法或属性时调用。
继承
pipe(StreamConsumer<List<int>> streamConsumer) → Future
将此流的的事件传入 streamConsumer。
继承
reduce(List<int> combine(List<int> previous, List<int> element)) → Future<List<int>>
通过反复应用 combine 函数来组合一个值序列。
继承
singleWhere(bool test(List<int> element), {List<int> orElse()?}) → Future<List<int>>
在此流中找到满足 test 条件的单个元素。
继承
skip(int count) → Stream<List<int>>
跳过此流中前 count 个数据事件。
继承
skipWhile(bool test(List<int> element)) → Stream<List<int>>
在满足 test 条件的情况下跳过此流中的数据事件。
继承
take(int count) → Stream<List<int>>
提供最多前 count 个此流的数据事件。
继承
takeWhile(bool test(List<int> element)) → Stream<List<int>>
在 test 顺利执行的情况下转发数据事件。
继承
timeout(Duration timeLimit, {void onTimeout(EventSink<List<int>> sink)?}) → Stream<List<int>>
创建一个与此流有相同事件的新流。
继承
toList() → Future<List<List<int>>>
将此流的所有元素收集到一个列表中。
继承
toSet() → Future<Set<List<int>>>
将此流中的数据收集到一个集合中。
继承
toString() → String
此对象的字符串表示。
继承
transform<S>(StreamTransformer<List<int>, S> streamTransformer) → Stream<S>
将 streamTransformer 应用到此流上。
继承
where(bool test(List<int> event)) → Stream<List<int>>
从一个流中创建一个新的流，丢弃一些元素。
继承

运算符

operator ==(Object other) → bool
相等运算符。
继承