print(i);
}
}

​

• Stream.takeWhile

上面这种方式我们是只制定了发送事件的个数，如果我们也不知道发送多少个事件，我们可以从返回的结果上做一个返回值的限制,上面结果也可以用以下方式实现

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
// stream = stream.take(10);
stream = stream.takeWhile((data) {
return data < 10;
});
await for (int i in stream) {
print(i);
}
}

​

• Stream.skip(int count)

skip可以指定跳过前面的几个事件,如下会跳过0和1，输出 2-9;

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
stream = stream.take(10);
stream = stream.skip(2);
await for (int i in stream) {
print(i);
}
}

​

• Stream.skipWhile

可以指定跳过不发送事件的指定条件，如下跳过0-4的输出，输出5-9

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
stream = stream.take(10);
stream = stream.skipWhile((data) => data<5);
await for (int i in stream) {
print(i);
}
}

​

• Stream.toList()

将流中所有的数据收集存放在List中，并返回 Future对象，listData里面 0-9

1.这个是一个异步方法，要结果则需要使用await关键字

2.这个是等待Stream当流结束时，一次返回结果

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
stream = stream.take(10);
List listData = await stream.toList();
for (int i in listData) {
print(i);
}
}

​

• Stream. listen()

这是一种特定的可以用于监听数据流的方式，和 forEach循环的效果一致，但是返回的是StreamSubscription<T>对象，如下也会输出0-9,同时打印出 ”流已完成“

看一下源码这种方式可以接收

StreamSubscription listen(void onData(T event),
{Function onError, void onDone(), bool cancelOnError});

1.onData是接收到数据的处理,必须要实现的方法

2.onError流发生错误时候的处理

3.onDone流完成时候调取

4.cancelOnError发生错误的时候是否立马终止

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
stream = stream.take(10);
stream.listen((data) {
print(data);
}, onError: (error) {
print(“流发生错误”);
}, onDone: () {
print(“流已完成”);
}, cancelOnError: false);
}

​

• Stream. forEach()

这中操作和listen()的方式基本差不多，也是一种监听流的方式，这只是监听了onData,下面代码也会输出0-9

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
stream = stream.take(10);
stream.forEach((data) {
print(data);
});
}

​

• Stream .length

用于获取等待流中所有事件发射完成之后统计事件的总数量,下面代码会输出 10

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
stream = stream.take(10);
var allEvents = await stream.length;
print(allEvents);
}

​

• Stream.where

在流中添加筛选条件，过滤掉一些不想要的数据，满足条件返回true,不满足条件返回false,如下我们筛选出流中大于5小于10的数据

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
stream = stream.where((data)=>data>5);
stream = stream.where((data)=> data<10);
await for(int i in stream){
print(i);
}
}

​

• stream.map

对流中的数据进行一些变换，以下是我对Stream的每个数据都加1

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
stream = stream.map((data) => data + 1);
await for (int i in stream) {
print(i);
}
}

​

• Stream.expand

对流中的数据进行一个扩展，如下，会输出1,1,2,2,3,3….

void _stream() async {
Duration interval = Duration(seconds: 1);
Stream stream = Stream.periodic(interval, (data) => data);
stream = stream.expand((data)=>[data,data]);
stream.listen((data)=>print(data),onError:(error)=> print(“发生错误”) );
}

• Stream.transform

如果我们在在流流转的过程中需要进行一些转换和控制我们则需要使用到transform,接收一个

StreamTransformer<S,T>，S表示转换之前的类型，T表示转换后的输入类型，如下代码我们会接收到三组数字模拟输入了三次密码，并判断真确的密码，同时输出密码正确和密码错误：

void _stream() async {
var stream = Stream.fromIterable([123456,234567,678901]);
var st = StreamTransformer<int, String>.fromHandlers(
handleData: (int data, sink) {
if (data == 678901) {
sink.add(“密码输入正确,正在开锁。。。”);
} else {
sink.add(“密码输入错误…”);
}
});
stream.transform(st).listen((String data) => print(data),
onError: (error) => print(“发生错误”));
}

输入如下结果

I/flutter (18980): 密码输入错误…
I/flutter (18980): 密码输入错误…
I/flutter (18980): 密码输入正确,正在开锁。。。

​

StreamController使用

​ 介绍完了Stream的基本概念和基本用法，上面直接创建流的方式，对我们本身开发来说，用途不是很大，我们在实际的开发过程中，基本都是使用的StreamContoller来创建流。通过源码我们可以知道Stream的几种构造方法，最终都是通过StreamController进行了包装。

​

创建StreamController对象及使用

• 构建单订阅的Streamcontroller

//StreamController里面会创建一个Stream，我们实际操控的Stream
StreamController streamController = StreamController();
streamController.stream.listen((data)=> print(data));
streamController.sink.add(“aaa”);
streamController.add(“bbb”);
streamController.add(“ccc”);
streamController.close();

//上面代码我们会输出 aaa,bbb,ccc

注意：如果我们给上面的代码再加一个listen会报如下异常,所以单订阅流，只能有一个listen。一般情况下我们多数都是使用的单订阅流，我们也可以将单订阅流转成多订阅流。

​

• 构建多监听器的StreamController有两种方式

1.直接创建多订阅Stream

StreamController streamController = StreamController.broadcast();
streamController.stream.listen((data){
print(data);
},onError: (error){
print(error.toString());
});
streamController.stream.listen((data) => print(data));
streamController.add(“bbb”);

//上面代码回输出 bbb,bbb

2.将单订阅流转成多订阅流

StreamController streamController = StreamController();
Stream stream =streamController.stream.asBroadcastStream();
stream.listen((data) => print(data));
stream.listen((data) => print(data));
streamController.sink.add(“aaa”);
streamController.close();

//上面代码会输出 aaa,aaa

注意：在流用完了之后记得关闭，调用streamController.close()

​

StreamBuilder使用

​    前面我把Stream的常用方式做了简单的介绍和演示，我们怎么结合Flutter使用呢？在Flutter里面提供了一个Widget叫StreamBuilder。 StreamBuilder其实是个StatefulWidget它一直记录着流中最新的数据，当数据流发生变化时，会自动调用builder方法进行重建。

​

• StreamBuilder的源码如下，需要接受一个流，我们可以传入一个StreamController的Stream

const StreamBuilder({
Key key,
this.initialData,
Stream stream,
@required this.builder,
}) : assert(builder != null),
super(key: key, stream: stream);

​

• 使用StreamController 结合 StreamBuider对官方的计数器进行改进，取代setState刷新页面，代码如下

class MyHomePage extends StatefulWidget {
@override
_MyHomePageState createState() => _MyHomePageState();
}

class _MyHomePageState extends State {
int _count = 0;
final StreamController _streamController = StreamController();

@override
Widget build(BuildContext context) {
return Scaffold(
body: Container(
child: Center(
child: StreamBuilder(
stream: _streamController.stream,
builder: (BuildContext context, AsyncSnapshot snapshot) {
return snapshot.data == null
? Text(“0”)
: Text(“${snapshot.data}”);
}),
),
),
floatingActionButton: FloatingActionButton(
child: const Icon(Icons.add),
onPressed: () {
_streamController.sink.add(++_count);
}),
自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。

深知大多数初中级Android工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则近万的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！

因此收集整理了一份《2024年Android移动开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。

既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Android开发知识点，真正体系化！

由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！

如果你觉得这些内容对你有帮助，可以扫码获取！！（备注：Android）

总结

Android架构学习进阶是一条漫长而艰苦的道路，不能靠一时激情，更不是熬几天几夜就能学好的，必须养成平时努力学习的习惯。所以：贵在坚持！

上面分享的字节跳动公司2020年的面试真题解析大全，笔者还把一线互联网企业主流面试技术要点整理成了视频和PDF（实际上比预期多花了不少精力），包含知识脉络 + 诸多细节。

就先写到这，码字不易，写的很片面不好之处敬请指出，如果觉得有参考价值的朋友也可以关注一下我

①「Android面试真题解析大全」PDF完整高清版+②「Android面试知识体系」学习思维导图压缩包阅读下载，最后觉得有帮助、有需要的朋友可以点个赞

《Android学习笔记总结+移动架构视频+大厂面试真题+项目实战源码》，点击传送门即可获取！

诸多细节。

就先写到这，码字不易，写的很片面不好之处敬请指出，如果觉得有参考价值的朋友也可以关注一下我

①「Android面试真题解析大全」PDF完整高清版+②「Android面试知识体系」学习思维导图压缩包阅读下载，最后觉得有帮助、有需要的朋友可以点个赞

[外链图片转存中…(img-Nzzc4AWs-1711816822882)]

[外链图片转存中…(img-KBR8FyuO-1711816822882)]

[外链图片转存中…(img-CiVrxQzQ-1711816822883)]

《Android学习笔记总结+移动架构视频+大厂面试真题+项目实战源码》，点击传送门即可获取！