import 'dart:async'; void main() {} createStream() async { Duration duration = Duration(seconds: 1); Stream<int> stream = Stream<int>.periodic(duration, (data) => data); //拦截处理,只获取0-9 stream = stream.take(10); //筛选流,只显示大于2小于6的流 // stream.where((data) => data > 2); // stream.where((data) => data < 6); //监听流 // stream.listen((data) { // print(data); // }, onDone: () { // print('流已完成'); // }, onError: (error) { // print('流发生错误'); // }, cancelOnError: false); //循环foreach // stream.forEach((val) { // print(val); // }); }
dart笔记17:stream流的监听、循环、筛选
dart笔记17:stream流的listen监听、forEach循环、where筛选: