部分代码的单独工作流程

异步编程是一种原则，允许您的程序的一部分在等待应用程序线程中发生的其他活动时运行。它允许您的部分代码独立于主工作流程运行。

异步过程的几个例子是：从网络获取数据，或循环一些非常大的数据块。

在Flutter中有一系列编写异步代码的方法。一些流行的方法是：

Future
Async/Await
Streams

这篇文章的目的是让你开始在你的flutter应用程序中使用流，我希望你有关于编写flutter应用程序的先验知识，让我们开始吧！

什么是反应式编程？

根据维基百科：

反应式编程是一种围绕数据流和变化传播的编程范例。这意味着应该可以在所使用的编程语言中轻松表达静态或动态数据流，并且底层执行模型将自动通过数据流传播更改。

在反应式编程中，数据在由您使用的语言，框架或库设置的结构中流动，使得当数据在一端传递到结构中时，如果该数据的值发生更改，则输出将始终自行更新。

这正是Steams所做的。流是异步事件流，将其视为包含液体的管道。你从管道的一端倒出液体，它从另一端出来。

流可以携带和处理不同类型的数据，如对象，函数，映射，列表，甚至流的流。太酷了呃？

代码示例

第一个示例创建一个简单的流，它接收一个字符串并在完成后将其打印出来：

@override
void initState() {
super.initState();
Stream<String> stream = new Stream.fromFuture(inputData());
stream.listen((data) {
print("Our data: " + data);
}, onDone: () {
print("Done");
}, onError: (error) {
print("Error returned");
});
}
Future<String> inputData() async {
print("Fetching Data...");
return "Let's Use Streams!";
}

输出

Fetching Data…
Our Data: Let’s use Streams!
Done

这里，Stream从inputData()返回文本的函数中获取数据“Let’s use streams!”。然后，我们用stream.listen()对输入流中的数据。在这里，我们有一个，和方法。在进程完成时使用数据，如果有的话可以用来抛出错误。onDone()``onError()``onDone()``onError()

第二个例子

final StreamController controller= StreamController();
controller.stream.listen((data) {
print("received data: $data");
}, onDone: () {
print("Stream done");
}, onError: () {
print("Error occured");
});
// data flowing into the stream
controller.sink.add('stream controllers are awesome');
controller.sink.add("Because You can do more");
controller.sink.add('random string');
// Close the StreamController when done to avoid memory leaks
controller.close();

输出

received data: stream controllers are awesome
received data: Because you can do more
received data: random string
Stream done

所述StreamController类创建为创建的任何流的控制器。让您更容易使用多个监听（我们很快就会开始）。这里我们使用添加数据[sink](https://api.flutter.dev/flutter/dart-async/StreamSink-class.html).add()，这是一个接受输入到流中的数据的对象。此外，您应该在使用后关闭控制器，以防止内存泄漏。

广播流

这种类型的流允许您使用多个侦听器。我们之前创建的流只能有一个监听器; 它们被称为单订阅流。

代码示例

@override
void initState() {
super.initState();
stream();
}
final StreamController controller = StreamController.broadcast(); //add a .broadcast() 
stream() {
controller.stream.where((data) => (data is String)).listen((data) {
print("DataReceived: " + data);
}, onDone: () {
print("Task 1 Done");
}, onError: (error) {
print("Some Error");
});
controller.stream.where((data) => (data is int)).listen((data) {
print("DataReceived: " + data.toString());
}, onDone: () {
print("Task 2 Done");
});
controller.stream.where((data) => (data is Map)).listen((data) {
print(data);
}, onDone: () {
print("Task 3 Done");
});
controller.sink.add('random string');
controller.sink.add(1234);
controller.sink.add({'key 1': 'value A', 'key 2': 'value B'});
controller.close();
}