大气建站工作室网站源码,广告设计培训班费用,做游戏网站教程,中国建设移动门户网站文章目录 1. 概念介绍2. 使用方法3. 示例代码 我们在上一章回中介绍了Flutter中的异步操作#xff0c;本章回中将介绍Flutter中的事件流.闲话休提#xff0c;让我们一起Talk Flutter吧。 1. 概念介绍
我们在上一章回中介绍了异步操作相关的内容#xff0c;本章回中将介绍如… 文章目录 1. 概念介绍2. 使用方法3. 示例代码 我们在上一章回中介绍了Flutter中的异步操作本章回中将介绍Flutter中的事件流.闲话休提让我们一起Talk Flutter吧。 1. 概念介绍
我们在上一章回中介绍了异步操作相关的内容本章回中将介绍如何把多个异步操作组成事件流。事件流是指让事件按照一定的顺序去执行我们介绍RxJava时介绍这方 面的内容感兴趣的看官可以去看看。Flutter提供了Stream类来实现事件流本章回中将介绍它的使用方法。
2. 使用方法
Stream类提供了一些静态方法来实现事件操作常用的是静态方法如下
fromFutures方法从Future数组中获取异步操作来组成事件流事件的顺序按照数组的索引值依次进行listen方法从事件流中获取事件的运行状态比如运行错误运行完成 我们重点介绍listen方法该方法以监听的方式运行它提供了三个方法类型的参数来监听事件的运行状态详细如下onData方法每个事件运行完成后都会执行该方法该方法是必选方法onError方法如果事件流中的某个事件运行时发生了错误那么回调该方法onDone方法所有事件运行完成后回调该方法表示事件流运行结束 这三个方法中只有第一个方法是必选方法最后两个方法是可选方法不过我还是建议大家把这三个方法都用起来特别是事件流中有错误发生可以获取到错误信息。 如果大家熟悉RxJava的话就地发现Stream的运行机制和RxJava的运行机制基本相同不熟悉的话也不用担心这种机制就是典型的观察者模式:fromFuture方法 对应的数组就是被观察者或者说事件流就是被观察者而listen方法就是观察者。
3. 示例代码
_syncMultiLauncher() {Stream.fromFutures([Future.delayed(Duration(seconds: 2),()debugPrint(do one),),// Future.delayed(Duration(seconds: 2),()debugPrint(do two),),Future.delayed(Duration(seconds: 2),(){throw AssertionError();},),Future.delayed(Duration(seconds: 2),()debugPrint(do three),),]).listen((event) {print(onData);},onDone:() print(onDone),onError: (v) print(onError),);
}在上面的代码中使用三个Future异步事件组成了事件流它的执行顺序按照它们在数组中的索引依次进行编译并且运行上面的程序可以得到以下运行结果 I/flutter ( 7402): do one I/flutter ( 7402): onData I/flutter ( 7402): onError I/flutter ( 7402): do three I/flutter ( 7402): onData I/flutter ( 7402): onDone 从程序运行结果中可以看到先运行事件流中的第一个事件:do one,listen()方法监听到该事件后运行onData方法接着运行事件流中的第二个事件该事件主动抛出 一个错误listen()方法监听到错误后运行onError方法注意它不会去运行onData方法最后运行第三个事件do three,listen()方法监听到该事件后运行 onData方法到目前为止事件流中的三个事件都已经运行结束此时listen()方法调用onDone方法表示事件流中的所有事件运行完成。
看官们关于Flutter中的事件流相关的内容就介绍到这里欢迎大家在评论区交流与讨论!
