MultiStreamController<T>抽象 接口

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
相等运算符。
继承