??前言
Stream和 Future都是Dart:async庫的核心API工腋，對異步提供了非常好的支持淌哟。
我思考了很久吏恭，究竟應(yīng)該如何向大家介紹Stream（流）。因為Stream非常有用兜粘，它是為處理異步事件而生的申窘。而在應(yīng)用中有大量的場景需要使用異步事件弯蚜，例如請求網(wǎng)絡(luò)孔轴，和用戶交互等等，它們都無法同步完成碎捺。Stream能夠極大的幫助我們處理這些問題路鹰。??
但是對于剛接觸的新手來說，流確實足夠抽象收厨，以至于大家需要花費非常多的時間來理解它晋柱。
所以我將會盡我所能向大家介紹Stream。
?????Stream
??什么是Stream
Stream非常有特點但卻不太好理解诵叁，我與其按照字面意思把它看作流雁竞，更愿意把它看成一個工廠或者是機器。
我們來看看這個機器它有什么特點：
- 它有一個入口拧额，可以放東西/指令（anything）
- 這個機器不知道入口什么時候會放東西進來
- 中間的機器能夠生產(chǎn)或者加工碑诉，這應(yīng)該會耗費一些時間
- 他有一個出口，應(yīng)該會有產(chǎn)品從那出來
- 我們也不知道到底什么時候產(chǎn)品會從出口出來
整個過程侥锦，時間都是一個不確定因素进栽，我們隨時都可以向這個機器的入口放東西進去，放進去了以后機器進行處理恭垦，但是我們并不知道它多久處理完快毛。所以出口是需要專門派人盯著的格嗅，等待機器流出東西來。整個過程都是以異步的眼光來看的唠帝。
??我們將機器模型轉(zhuǎn)化成Stream
- 這個大機器就是StreamController屯掖，它是創(chuàng)建流的方式之一。
- StreamController有一個入口襟衰，叫做sink
- sink可以使用add方法放東西進來懂扼，放進去以后就不再關(guān)心了。
- 當(dāng)有東西從sink進來以后右蒲，我們的機器就開始工作啦阀湿，空空空。
- StreamController有一個出口瑰妄，叫做stream
- 機器處理完畢后就會把產(chǎn)品從出口丟出來陷嘴，但是我們并不知道什么時候會出來，所以我們需要使用listen方法一直監(jiān)聽這個出口间坐。
- 而且當(dāng)多個物品被放進來了之后灾挨，它不會打亂順序，而是先入先出竹宋。
通過這個例子劳澄，相信大家對流應(yīng)該都有了基礎(chǔ)印象，那么要解釋后面的東西就不難了蜈七。
??如何使用Stream
獲得Stream的方法：
- 通過構(gòu)造函數(shù)
- 使用StreamController
- IO Stream
stream有三個構(gòu)造方法：
Stream.fromFuture:從Future創(chuàng)建新的單訂閱流,當(dāng)future完成時將觸發(fā)一個data或者error秒拔，然后使用Down事件關(guān)閉這個流。
Stream.fromFutures:從一組Future創(chuàng)建一個單訂閱流飒硅，每個future都有自己的data或者error事件棍厌，當(dāng)整個Futures完成后寸谜，流將會關(guān)閉。如果Futures為空，流將會立刻關(guān)閉弄慰。
Stream.fromIterable:創(chuàng)建從一個集合中獲取其數(shù)據(jù)的單訂閱流篓叶。
Stream.fromIntreable([1,2,3]);
??監(jiān)聽Stream的方法
監(jiān)聽一個流最常見的方法就是listen寺枉。當(dāng)有事件發(fā)出時在塔，流將會通知listener。Listen方法提供了這幾種觸發(fā)事件：
- onData(必填)：收到數(shù)據(jù)時觸發(fā)
- onError：收到Error時觸發(fā)
- onDone：結(jié)束時觸發(fā)
- unsubscribeOnError：遇到第一個Error時是否取消訂閱会前，默認為false
?? StreamController
如果你想創(chuàng)建一條新的流的話好乐，非常簡單！?? 使用StreamController回官，它為你提供了非常豐富的功能曹宴，你能夠在streamController上發(fā)送數(shù)據(jù)，處理錯誤歉提，并獲得結(jié)果笛坦！
//任意類型的流
StreamController controller = StreamController();
controller.sink.add(123);
controller.sink.add("xyz");
controller.sink.add(Anything);
//創(chuàng)建一條處理int類型的流
StreamController<int> numController = StreamController();
numController.sink.add(123);
泛型定義了我們能向流上推送什么類型的數(shù)據(jù)区转。它可以是任何類型！
我們再來看看如何獲取最后的結(jié)果版扩。
StreamController controller = StreamController();
//監(jiān)聽這個流的出口废离，當(dāng)有data流出時，打印這個data
StreamSubscription subscription =
controller.stream.listen((data)=>print("data"));
controller.sink.add(123);
輸出: 123
你需要將一個方法交給stream的listen函數(shù)礁芦，這個方法入?yún)?data)是我們的StreamController處理完畢后產(chǎn)生的結(jié)果蜻韭，我們監(jiān)聽出口，并獲得了這個結(jié)果(data)柿扣。這里可以使用lambda表達式肖方，也可以是其他任何函數(shù)。
（這里我為了方便區(qū)分未状，把listen說成函數(shù)俯画，(data)=>print(data)說成方法，其實是一個東西司草。）
??Transforming an existing stream
假如你已經(jīng)有了一個流艰垂，你可以通過它轉(zhuǎn)化成為一條新的流。非常簡單埋虹！流提供了map()猜憎，where()，expand()搔课，和take()方法胰柑，能夠輕松將已有的流轉(zhuǎn)化為新的流。
where
如果你想要篩選掉一些不想要的事件辣辫。例如一個猜數(shù)游戲旦事，用戶可以輸入數(shù)字，當(dāng)輸入正確的時候急灭，我們做出一定反應(yīng)。而我們必須篩選掉所有錯誤的答案谷遂，這個時候我們可以使用where篩選掉不需要的數(shù)字葬馋。
stream.where((event){...})
where函數(shù)接收一個事件，每當(dāng)這個流有東西流到where函數(shù)的時候肾扰，這就是那個事件畴嘶。我們或許根本不需要這個事件，但是必須作為參數(shù)傳入集晚。
take
如果你想要控制這個流最多能傳多少個東西窗悯。比如輸入密碼，我們可能想讓用戶最多輸四次偷拔，那么我們可以使用take來限制蒋院。
stream.take(4);
take函數(shù)接收一個int亏钩，代表最多能經(jīng)過take函數(shù)的事件次數(shù)。當(dāng)傳輸次數(shù)達到這個數(shù)字時欺旧，這個流將會關(guān)閉姑丑，無法再傳輸。
transform
如果你需要更多的控制轉(zhuǎn)換辞友，那么請使用transform()方法栅哀。他需要配合StreamTransformer進行使用。我們先來看下面一段猜數(shù)游戲称龙，然后我會向你解釋留拾。
StreamController<int> controller = StreamController<int>();
final transformer = StreamTransformer<int,String>.fromHandlers(
handleData:(value, sink){
if(value==100){
sink.add("你猜對了");
}
else{ sink.addError('還沒猜中，再試一次吧');
}
});
controller.stream
.transform(transformer)
.listen(
(data) => print(data),
onError:(err) => print(err));
controller.sink.add(23);
//controller.sink.add(100);
輸出: 還沒猜中鲫尊，再試一次吧
StreamTransformer<S,T>是我們stream的檢查員间驮，他負責(zé)接收stream通過的信息，然后進行處理返回一條新的流马昨。
- S代表之前的流的輸入類型竞帽，我們這里是輸入一個數(shù)字，所以是int鸿捧。
- T代表轉(zhuǎn)化后流的輸入類型屹篓，我們這里add進去的是一串字符串，所以是String匙奴。
- handleData接收一個value并創(chuàng)建一條新的流并暴露sink堆巧，我們可以在這里對流進行轉(zhuǎn)化。
- 我們還可以addError進去告訴后面有問題泼菌。
然后我們監(jiān)聽transform之后的流谍肤，當(dāng)轉(zhuǎn)換好的event流出時，我們打印這個event哗伯，這個event就是我們剛才add進sink的數(shù)據(jù)荒揣。onError能夠捕捉到我們add進去的err。
??Stream的種類
流有兩種
- "Single-subscription" streams 單訂閱流
- "broadcast" streams 多訂閱流
"Single-subscription" streams
單個訂閱流在流的整個生命周期內(nèi)僅允許有一個listener焊刹。它在有收聽者之前不會生成事件系任，并且在取消收聽時它會停止發(fā)送事件，即使你仍然在Sink.add更多事件虐块。
即使在第一個訂閱被取消后俩滥，也不允許在單個訂閱流上進行兩次偵聽。
單訂閱流通常用于流式傳輸更大的連續(xù)數(shù)據(jù)塊贺奠，如文件I / O.
StreamController controller = StreamController();
controller.stream.listen((data)=> print(data));
controller.stream.listen((data)=> print(data));
controller.sink.add(123);
輸出： Bad state: Stream has already been listened to.
單訂閱流不能有多個收聽者霜旧。
"Broadcast" streams
廣播流允許任意數(shù)量的收聽者，且無論是否有收聽者儡率，他都能產(chǎn)生事件挂据。所以中途進來的收聽者將不會收到之前的消息以清。
如果多個收聽者想要收聽單個訂閱流，請使用asBroadcastStream在非廣播流之上創(chuàng)建廣播流棱貌。
如果在觸發(fā)事件時將收聽者添加到廣播流玖媚，則該偵聽器將不會接收當(dāng)前正在觸發(fā)的事件。如果取消收聽婚脱，收聽者會立即停止接收事件今魔。
一般的流都是單訂閱流。從Stream繼承的廣播流必須重寫isBroadcast 才能返回true障贸。
StreamController controller = StreamController();
//將單訂閱流轉(zhuǎn)化為廣播流
Stream stream = controller.stream.asBroadcastStream();
stream.listen((data)=> print(data));
stream.listen((data)=> print(data));
controller.sink.add(123);
輸出：
123
123
?? 寫在最后
以上就是關(guān)于Dart中Stream的簡單介紹错森，如果你還有任何疑問或者建議，歡迎在下方評論區(qū)或者郵箱告訴我篮洁！我會在24小時內(nèi)盡快聯(lián)系您??
下一篇文章我將向大家介紹一種非常棒的狀態(tài)管理方式涩维，它是Google團隊力推的狀態(tài)管理方法，我認為它真的很酷袁波！
所以瓦阐，準(zhǔn)備好迎接BLoC了嗎??
