前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >【Flutter 专题】82 初识 Flutter Stream (二)

【Flutter 专题】82 初识 Flutter Stream (二)

作者头像
阿策小和尚
发布2020-04-08 15:48:26
1.3K0
发布2020-04-08 15:48:26
举报
文章被收录于专栏:阿策小和尚

和尚上周刚学习了 Stream 的部分方法,对 Stream 流的认知还很浅显,今天继续学习基础的 Stream 方法;

Stream Types

Single-Subscription

Single-Subscription 为单一订阅流,是最常见的 Stream 类型,这种方式只能被监听一次,若多次监听会导致 error

代码语言:javascript
复制
var data = [1, 2, '3.toString()', true, true, false, true, 6];
Stream stream = Stream.fromIterable(data).distinct();
stream
    .listen((event) => print('Liste1 -> Stream.fromIterable -> $event'))
    .onDone(() => print('onDone1 -> Stream.fromIterable -> done 结束'));
stream
    .listen((event2) => print('Liste2 -> Stream.fromIterable -> $event2'))
    .onDone(() => print('onDone2 -> Stream.fromIterable -> done 结束'));
Broadcast

Broadcast 为广播订阅流,允许任意数量的接收者,这种方式可以在同一时间设置多个不同的监听器同时监听,同时你也可以在取消上一个订阅后再次对其发起监听;单一订阅流可以通过 asBroadcastStream 方式创建广播流;

代码语言:javascript
复制
var data = [1, 2, '3.toString()', true, true, false, true, 6];
Stream stream = Stream.fromIterable(data).distinct();
stream = stream.asBroadcastStream();
stream
    .listen((event) => print('Liste1 -> Stream.fromIterable -> $event'))
    .onDone(() => print('onDone1 -> Stream.fromIterable -> done 结束'));
stream
    .listen((event2) => print('Liste2 -> Stream.fromIterable -> $event2'))
    .onDone(() => print('onDone2 -> Stream.fromIterable -> done 结束'));

Listener

和尚在之前的测试 Code 中都使用了 Listener,当 Stream 事件发出时可以通过 Listener 监听其状态;

代码语言:javascript
复制
StreamSubscription<T> listen(void onData(T event),
      {Function onError, void onDone(), bool cancelOnError});

StreamController

StreamControllerStream 的控制器,允许发送数据、错误事件、结束事件给 Stream;可以用来检测 Stream 是否已暂停,是否有订阅者,以及变更时获取的回调;和尚分析源码,Stream 很多方法都是通过 StreamController 进行创建的;

StreamController 默认是对单一数据流进行控制;

代码语言:javascript
复制
factory StreamController(
      {void onListen(),
      void onPause(),
      void onResume(),
      onCancel(),
      bool sync: false}) {
    return sync
        ? new _SyncStreamController<T>(onListen, onPause, onResume, onCancel)
        : new _AsyncStreamController<T>(onListen, onPause, onResume, onCancel);
}
  1. 通过 skinStreamController 中添加数据;
  2. 通过 StreamController.stream 设置 Listener 监听;
  3. 若不设置 StreamController.close() 则不会监听到 onDone 方法,且 close() 之后不可继续添加事件或监听事件;
  4. 使用 StreamController 与单纯的 Listener 方式一样,单一信息流不可多次监听,需要转成广播流;
  5. 如果 Stream 直接监听 onDone 方法和通过 listener 中监听 onDone 方法,以 Stream 直接监听方法为准;

和尚尝试用 sink 方式向 StreamController 中添加数据,目前最后一个 'test' 是在你 listen 之后设置,依旧可以正常监听,但此时没有监听到 onDone 方法;

代码语言:javascript
复制
var data = [1, 2, '3.toString()', true, true, false, true, 6];
var controller = StreamController();
for (int i = 0; i < data.length; i++) {
  controller.sink.add(data[i]);
}
controller.stream.listen(
    (event) => print('Liste1 -> Stream.fromIterable -> $event'),
    onDone: () => print('onDone -> Stream.fromIterable -> done 结束'));
controller.sink.add('test');

和尚继续尝试在 'test' 之前调用 StreamController.close() 此时 StreamController 监听的是 close() 之前的数据并提示不能在 close 之后继续添加事件,且可以监听到 onDone 方法;

代码语言:javascript
复制
var data = [1, 2, '3.toString()', true, true, false, true, 6];
var controller = StreamController();
for (int i = 0; i < data.length; i++) {
  controller.sink.add(data[i]);
}
controller.stream.listen(
    (event) => print('Liste1 -> Stream.fromIterable -> $event'),
    onDone: () => print('onDone -> Stream.fromIterable -> done 结束'));
controller.close();
controller.sink.add('test');

和尚尝试通过 Stream 监听 onDoneListener 中监听 onDone 两种方式,以 Stream 直接监听 onDone 方式为准;

代码语言:javascript
复制
var data = [1, 2, '3.toString()', true, true, false, true, 6];
var controller = StreamController();
for (int i = 0; i < data.length; i++) {
  controller.sink.add(data[i]);
}
controller.stream
    .distinct()
    .listen((event) => print('Liste1 -> Stream.fromIterable -> $event'),
        onDone: () => print('onDone -> Stream.fromIterable -> done 结束'))
    .onDone(() => print('onDone1 -> Stream.fromIterable -> done 结束'));
controller.close();

和尚测试 StreamController.stream 获取的便是 Stream 可以设置滤重等方法;对于单一订阅流来说,依旧不能进行多个 Listener 监听,需要转换为广播流进行多处监听;

代码语言:javascript
复制
var data = [1, 2, '3.toString()', true, true, false, true, 6];
var controller = StreamController();
for (int i = 0; i < data.length; i++) {
  controller.sink.add(data[i]);
}
Stream stream = controller.stream.distinct();
stream.listen((event) => print('Liste1 -> Stream.fromIterable -> $event'))
    .onDone(() => print('onDone1 -> Stream.fromIterable -> done 结束'));
stream.listen((event) => print('Liste2 -> Stream.fromIterable -> $event'))
    .onDone(() => print('onDone2 -> Stream.fromIterable -> done 结束'));
controller.close();
代码语言:javascript
复制
Stream stream = controller.stream.distinct().asBroadcastStream();
stream.listen((event) => print('Liste1 -> Stream.fromIterable -> $event'))
    .onDone(() => print('onDone1 -> Stream.fromIterable -> done 结束'));
stream.listen((event) => print('Liste2 -> Stream.fromIterable -> $event'))
    .onDone(() => print('onDone2 -> Stream.fromIterable -> done 结束'));
controller.close();

和尚对 StreamStreamController 的研究依旧很浅显,需要在实际应用中探索,也为 BLoc 的学习做基础;如有错误请多多指导!

来源:阿策小和尚

本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2020-04-05,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 阿策小和尚 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • Stream Types
    • Single-Subscription
      • Broadcast
      • Listener
      • StreamController
      领券
      问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档