StreamController<T> 类 抽象 接口

控制其流的一个控制器。

此控制器允许在其 流 上发送数据、错误和完成事件。

此类可用于创建一个其他人可以监听的简单流，并将事件推送到该流。

可以检查流是否已暂停，以及是否有订阅者，还可以在其中一个更改时获取回调。

示例

final streamController = StreamController(
  onPause: () => print('Paused'),
  onResume: () => print('Resumed'),
  onCancel: () => print('Cancelled'),
  onListen: () => print('Listens'),
);

streamController.stream.listen(
  (event) => print('Event: $event'),
  onDone: () => print('Done'),
  onError: (error) => print(error),
);

要检查流上是否有订阅者，请使用 hasListener。

var hasListener = streamController.hasListener; // true

要向流发送数据事件，请使用 add 或 addStream。

streamController.add(999);
final stream = Stream<int>.periodic(
    const Duration(milliseconds: 200), (count) => count * count).take(4);
await streamController.addStream(stream);

要向流发送错误事件，请使用 addError 或 addStream。

streamController.addError(Exception('Issue 101'));
await streamController.addStream(Stream.error(Exception('Issue 404')));

要检查流是否已关闭，请使用 isClosed。

var isClosed = streamController.isClosed; // false

要关闭流，请使用 close。

await streamController.close();
isClosed = streamController.isClosed; // true