一、什么是Stream？
众所周知，dart是单线程语言，所以异步就非常重要的。而Stream就是处理异步事件的。rxdart，Bloc，flutter_redux,fish_redux都对Stream做了封装。Stream是dart语言自带的。
Stream从表面意思来看就是流，使用RxJava的朋友应该是很熟悉的，它们都是对把事件放到流上处理。核心设计模式就是观察者模式。
二、如何创建一个Stream
- 通过构造方法
- 使用StreamController
1.Stream有三种构造方法
- Stream.fromFuture(Future<T> future);传递一个异步任务Future就可以创建一个Stream。使用如下：
Stream stream = Stream.fromFuture(Future.delayed(Duration(seconds: 1),(){
return "Hello Stream";
}));
stream.listen((event) {
print(event);
},onError: (e){
print("onError");
},onDone: (){
print("onDone");
});
}
事件正常会走 print(event);打印出"Hello Stream"。如果Future中的处理逻辑报错会走 print("onError");不管有没有报错，处理完成都会走 print("onDone");
- Stream.fromFutures（Iterable<Future<T>> futures）一组Future订阅一个单订阅流，每个Future都会触发data或者error回调，整个完成之后会回调onDone，然后关闭流。使用如下：
Stream stream = Stream.fromFutures([getFuture(1,"hello Stream1"),getFuture(2,"hello Stream2"),
getFuture(3,"hello Stream3")]);
stream.listen((event) {
print(event);
},onError: (e){
print("onError:$e");
}).onDone(() {
print("onDone");
});
///创建Future
Future getFuture(int seconds,String result){
return Future.delayed(Duration(seconds: seconds),(){
return result;
});
}
打印结果如下：
I/flutter ( 4923): hello Stream1
I/flutter ( 4923): hello Stream2
I/flutter ( 4923): hello Stream3
I/flutter ( 4923): onDone
- Stream.fromIterable(Iterable<T> elements):从一个集合中获取数据的单订阅流。每个数据都会有自己的回调。使用如下：
Stream.fromIterable(["a", "b", "c"]).listen((event) {
print(event);
}, onError: (e) {
print(e);
}).onDone(() {
print("onDone");
});
打印结果：
I/flutter ( 4923): a
I/flutter ( 4923): b
I/flutter ( 4923): c
I/flutter ( 4923): onDone
2.通过StreamController 创建Stream
- 创建StreamController
- 获取StreamSink用作事件入口
- 使用stream对象用于监听
- 通过监听得到的StreamSubscription管理订阅事件，最后在不需要的时候关闭即可。
import 'dart:async';
class DataBloc {
///定义一个controller
StreamController<List<String>> _dataController = StreamController<List<String>>();
///获取StramSink 做add入口
StreamSink<List<String>> get dataSink => _dataController.sink;
///获取Stream 用于监听
Stream<List<String>> get dataStream => _dataController.stream;
///时间订阅对象
StreamSubscription _dataSubscription;
init() {
///监听事件
_dataSubscription = dataStream.listen((value){
print("dataStream 监听到了");
print("$value");
});
///添加时间
dataSink.add(["first","second","three","more"]);
}
close(){
///关闭
_dataSubscription.cancel();
_dataController.close();
}
}
三、Steam的种类
流有两种：
- "Single-subscription" streams 单订阅流，只允许订阅一次，当有多个订阅者的时候会报如下错误""Bad state: Stream has already been listened to.
- "broadcast" streams 多订阅流 后面的订阅者不会接收到之前的事件。而单订阅流中，订阅者是可以接收到订阅之前的事件。
单订阅流可以通过如下代码转换成多订阅流。
Stream stream = dataStream.asBroadcastStream();
四、StreamBuilder
StreamBuilder是Flutter中的一个Widget，它可以和Steam结合起来使用。如下：
child:StreamBuilder<List<String>>(
stream: dataBloc.dataStream,
initialData: ["none"],
builder: (BuildContext context,AsyncSnapshot<List<String>> snapshot){
///snapshot 是数据快至的意思
var data = snapshot.data;
print("$data");
return Text("helloe");
},
) ,
上面的steam接受一个流，initData可以接受一个初始化事件。在builder里面处理接收到的信息，然后渲染到子控件中。
五、Stream的异步实现
首先要说下dart的异步实现：dart是单线程语言，和大多单线程语言一样，dart是通过消息循环机制来运行的。这里面主要包括两个：一个是microtask的内部队列，一个是event的外部队列。microtask的优先级高于evnet的优先级。
dart中的触摸，io，点击，滑动，绘制都属于event外部队列。microTask内部队列主要由dart内部产生，stream中执行的异步模式就是StreamMicrotask。microtask优先级高于event外部事件，所以太多的微任务（microtask）会造成绘制，点击的阻塞卡顿。
最后附上参考连接
https://www.jianshu.com/p/b7cca3a89618?utm_source=desktop&utm_medium=timeline
