flutterbloc,flutterbloc add 无效

Flutter响应式编程 - RxDart

在上一篇文章中我们了解到Stream及响应式编程的相关概念，本文着重介绍在引入 RxDart 三方库后，不同Subject在实际开发中的应用场景。

先附上演示项目代码： flutter_movie

RxDart 是基于 ReactiveX 标准API的Dart版本实现，由Dart标准库中Stream扩展而成。因此，RxDart与Dart的相关术语稍有区别：

Observable 等同于 Stream ， Subject 等同于 StreamController ，前者均由后者继承而来。

不同于Dart，RxDart提供了三种StreamController的变体来应用到不同的场景：

PublishSubject是最普通的广播StreamController，和StreamController唯一的区别是它返回对象是Observable，而StreamController返回的是Stream。

PublishSubject PublishSubject

从图中可以了解到，listener只能监听到订阅之后的事件。

示例代码：

BehaviorSubject也是广播StreamController，和PublishSubject的区别是它会额外返回订阅前的最后一次事件。

BehaviorSubject BehaviorSubject

示例代码：

ReplaySubject也是广播StreamController，从字面上可以了解到它可以回放已经消失的事件。

ReplaySubject ReplaySubject

示例代码：

上文提到 StreamBuilder 作为Flutter中根据Stream生成Widget的便利工具，这里结合Subject来一起使用。

tab_bar.dart - 01 tab_bar.dart - 01 tab_bar.dart - 02 tab_bar.dart - 02

以上代码实现了一个简单的TabBar（或Segment），该Widget被定义成为一个StatefulWidget（因为它在点击交互后有更新高亮索引的需求）。

在 build 函数内部我们就使用了StreamBuilder来构建UI，它监听的数据源为BLoc的 tabList ，在builder闭包内部才是实际的UI构建代码。

tab_bloc.dart tab_bloc.dart

至于 tab_bloc.dart 则更加简单，他从构造函数接收一个字符串类型的List，然后使用ReplaySubject包装数据，

同时暴露出stream类型的对象 tabList 供外部订阅（即 tab_bar.dart 中第44行代码中的stream）。

最后，我们来看看完整的调用流程。

main.dart main.dart

在 main.dart 第30~50行代码中，我们使用了 BlocProvider 来管理bloc（对于BlocProvider深入了解可以参考上一篇文章的相关部分），

provider包裹的是整个 HomePage 这使得在page内部任何地方访问到bloc成为可能。

home.dart home.dart

在 home.dart 第38，39行代码中，我们使用provider获取bloc，并完成对TabBar的初始化。

更进一步，上篇文章提到的StreamTransformer可以对Stream进行相应的处理，同样的，RxDart中也支持类似的操作，它们被称为 操作符 。

search_list_bloc.dart search_list_bloc.dart

在上述稍显复杂的示例中，实现了基本的分页搜索功能。其中13~17行代码完成搜索索引位置监听前的处理，包括 采样 （按时间采样的缓存操作）、过滤、去重操作。

换句话说，在最终监听到start之前，我们都可以对Observable对象进行一系列地处理以达到数据使用方的需求。

相信很多人对于Flutter系列的开篇以响应式编程为主题表示有点异议，但谷歌官方推行这一架构必然有其合理性，无论是状态管理上还是Dart的原生支持上而言。

在学习新技术时不仅要学习语言的语法，更要理解其架构思想（新瓶装旧酒，Flutter和Dart是新瓶，响应式编程的思想是旧酒），将思维转变过来才能更加快速地获得新技术为我们带来的便利性。

后续的文章将围绕文章开头的demo项目进行展开，尽请期待~

Flutter状态管理（五）：Redux

Flutter状态管理系列：

Flutter状态管理（一）：ScopedModel

Flutter状态管理（二）：Provider

Flutter状态管理（三）：BLoC（Business Logic Component）

Flutter状态管理（四）：ReactiveX之RxDart

Flutter状态管理（五）：Redux

有做过H5前端开发的朋友应该很早就接触过这个，Redux在React/VUE中，与在Flutter/Dart中概念一样，没有任何区别；唯一的区别只是使用上的不同。

它主要由三部分组成：

下图是一个完整的数据触发及更新流程：

我们看到上面整个数据流，都是单向的，由View发起，最后到View的更新；

为啥这样设计？

小节二介绍了Redux最基本的原理，但是，如何用Redux来做一些异步操作，比如：加载数据、请求API等？这里就引出来了Redux的中间件（Middleware），中间件能够让我们使得action在到达reducer之前，做些其它“动作”！有了中间件，我们不但可以请求API，还可以改变action，使得分发到其它reducer中去；

上图是有Middleware的流程图。

Redux在Flutter中的使用与在JavaScript中的使用方式稍微有点不同，为啥？

因为JavaScript是弱类型语言，而Dart是强类型语言，这就使得在JS中每个reducer可以独立管理，而在Flutter中需要由一个大对象来管理！

无论在JS中还是在Flutter中，通常都将action、reducer、store各自建一目录，放在redux目录下，目录结构如下：

ReduxPage在build中，也可以直接用StoreBuilder（参考ReduxPage2中写法），因为StoreBuilder也是InheritedWidget。

正因为Redux在Flutter中与在JS中不同，因此，在Flutter中，建议：

flutter_bloc使用解析

初始化问题：这边初始化是在bloc里，直接在构造方法里面赋初值的，state中一旦变量多了，还是这么写，会感觉极其难受，不好管理。需要优化

如果进行一个页面，需要进行复杂的运算或者请求接口后，才能知晓数据，进行赋值，这里肯定需要一个初始化入口，初始化入口需要怎样去定义呢？

首先对state进行优化，新增俩个方法：init()和clone()

init()：这里初始化统一用init()方法去管理。

clone()：这边克隆方法，是非常重要的，一旦变量达到俩位数以上，就能深刻体会该方法是多么的重要。

定义一个与初始化state相对应的init()初始化方法

这增加了初始化方法，请注意，如果需要进行异步请求，同时需要将相关逻辑提炼一个方法，咱们在这里配套Future和await就能解决在异步场景下同步数据问题.

这里使用了克隆方法，可以发现，我们只要关注自己需要改变的变量就行了，其它的变量都在内部赋值好了，我们不需要去关注；这就大大的便捷了页面中有很多变量，只需要变动一俩个变量的场景。

view层增加了个初始化事件。初始化操作直接在创建的时候，在XxxBloc上使用add()方法就行了，就能起到进入页面，初始化一次的效果。

bloc的思想

观察者模式的思想；观察者（回调刷新控件）和被观察者（产生相应事件，添加事件，去通知观察者），bloc层是处于观察者和被观察者中间的一层，我们可以在bloc里面搞业务，搞逻辑，搞网络请求；拿到Event事件传递过来的数据，把处理好的、符合要求的数据返回给view层的观察者就行了。

Flutter Bloc实现原理

1、继承SingleChildStatelessWidget，就是一个widget，通过create 传入一个Bloc对象

1、Bloc继承自BlocBase，BlocBase中创建了StreamController对象，为多订阅对象

其中onCounterEvent((event, emit)为初始化创建_eventController监听

2、Bloc中创建_eventController，为事件通知

3、BlocBase创建_stateController,为状态刷新通知

4、add方法是执行广播通知

5、处理完数据之后执行emit()方法，其中emit方法是stateController广播

1、 BlocBuilder继承自BlocBuilderBase，_BlocBuilderBaseState中build方法返回的是BlocListener

2、BlocListener继承BlocListenerBase，_BlocListenerBaseState中_subscribe()添加监听stateController广播通知