MultiStreamController<T> 类抽象 接口

是由 Stream.multi 提供的一个增强型流控制器。

它的行为像一个普通的异步控制器，但也允许同步添加事件。与任何同步事件传递一样，发送者应该非常小心，不要在新的监听器可能还没有准备好接收它们的时候发送事件。这通常意味着只有在异步事件可能发生的时机才同步传递事件。

实现类型

注解

构造函数

done → Future: 当流控制器完成发送事件时完成的 future。
no setterinherited
hashCode → int: 该对象的哈希码。
no setterinherited
hasListener → bool: 是否有订阅者在 Stream 上。
no setterinherited
isClosed → bool: 流控制器是否已关闭以添加更多事件。
no setterinherited
isPaused → bool: 订阅是否需要缓冲事件。
no setterinherited
onCancel ↔ (FutureOr<void> Function()?): 在流被取消时调用的回调。
getter/setter pairinherited
onListen ↔ (void Function()?): 在流被监听时调用的回调。
getter/setter pairinherited
onPause ↔ (void Function()?): 在流被暂停时调用的回调。
getter/setter pairinherited
onResume ↔ (void Function()?): 在流被恢复时调用的回调。
getter/setter pairinherited
runtimeType → Type: 对象的运行时类型的表示。
no setterinherited
sink → StreamSink<T>: 返回一个仅公开 StreamSink 接口的此对象的视图。
no setterinherited
stream → Stream<T>: 此控制器控制的流。
no setterinherited

add(T event) → void: 发送一个数据 事件。
继承
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: 此对象的一个字符串表示。
继承