2分钟
02 Stream 的简单使用
如下代码所示，Stream 的使用并不复杂，一般我们只需要：
- 创建
StreamController， - 然后获取
StreamSink用做事件入口， - 获取
Stream对象用于监听， - 并且通过监听得到
StreamSubscription管理事件订阅，最后在不需要时关闭即可，看起来是不是很简单？
class DataBloc {
///定义一个Controller
StreamController<List<String>> _dataController = StreamController<List<String>>();
///获取 StreamSink 做 add 入口
StreamSink<List<String>> get _dataSink => _dataController.sink;
///获取 Stream 用于监听
Stream<List<String>> get _dataStream => _dataController.stream;
///事件订阅对象
StreamSubscription _dataSubscription;
init() {
///监听事件
_dataSubscription = _dataStream.listen((value){
///do change
});
///改变事件
_dataSink.add(["first", "second", "three", "more"]);
}
close() {
///关闭
_dataSubscription.cancel();
_dataController.close();
}
}在设置好监听后，之后每次有事件变化时， listen 内的方法就会被调用，同时你还可以通过操作符对 Stream 进行变换处理。
如下代码所示，是不是一股 rx 风扑面而来？
_dataStream.where(test).map(convert).transform(streamTransformer).listen(onData);而在 Flutter 中， 最后结合 StreamBuilder , 就可以完成 基于事件流的异步状态控件 了！
StreamBuilder<List<String>>(
stream: dataStream,
initialData: ["none"],
///这里的 snapshot 是数据快照的意思
builder: (BuildContext context, AsyncSnapshot<List<String>> snapshot) {
///获取到数据，为所欲为的更新 UI
var data = snapshot.data;
return Container();
});那么问题来了，它们内部究竟是如果实现的呢？原理是什么？各自的作用是什么？都有哪些特性呢？后面我们将开始深入解析这个逻辑 。
学员评价