由 Stream.multi 提供的增强型流控制器。
它像一个普通的异步控制器,但也允许同步添加事件。与任何同步事件交付一样,发送者应该非常小心,不要在新的监听者可能还没有准备好接收事件的时间交付事件。这通常意味着只有在响应其他异步事件时才同步交付事件,因为那时异步事件可能会发生。
- 实现类型
- 注释
-
- @Since("2.9")
属性
- done → Future
- 当流控制器完成发送事件时完成的未来。无设置器继承
- hashCode → int
- 此对象的哈希码。无设置器继承
- hasListener → bool
- 是否有订阅者在 Stream 上。无设置器继承
- isClosed → bool
- 流控制器是否已关闭以添加更多事件。无设置器继承
- isPaused → bool
- 订阅是否需要缓冲事件。无设置器继承
-
onCancel ↔ (FutureOr<
void> Function()?) - 当流被取消时调用的回调。getter/setter 对继承
- onListen ↔ (void Function()?)
- 当流被监听时调用的回调。getter/setter 对继承
- onPause ↔ (void Function()?)
- 当流被暂停时调用的回调。getter/setter 对继承
- onResume ↔ (void Function()?)
- 当流被恢复时调用的回调。getter/setter 对继承
- runtimeType → Type
- 对象运行时类型的表示。无设置器继承
-
sink → StreamSink<
T> - 返回此对象的视图,只暴露 StreamSink 接口。无设置器继承
-
stream → Stream<
T> - 控制器所控制的流。无设置器继承
方法
-
add(
T event) → void - 发送一个数据
event
。继承 -
addError(
Object error, [StackTrace? stackTrace]) → void - 发送或排队错误事件。继承
-
addErrorSync(
Object error, [StackTrace? stackTrace]) → void - 添加并传递错误事件。
-
addStream(
Stream< T> source, {bool? cancelOnError}) → Future - 从
source
接收事件并将它们放入此控制器的流中。继承 -
addSync(
T value) → void - 添加并传递事件。
-
close(
) → Future - 关闭流。继承
-
closeSync(
) → void - 关闭控制器并传递完成事件。
-
noSuchMethod(
Invocation invocation) → dynamic - 当访问不存在的方法或属性时调用。继承
-
toString(
) → String - 此对象的字符串表示。继承
运算符
-
operator ==(
Object other) → bool - 相等运算符。继承