20、在RxCpp中创建自定义操作符

在RxCpp中创建自定义操作符

1. RxCpp中Observable/Observer交互的一般用法

RxCpp中Observable/Observer交互的一般伪代码用法如下：

Observable(). // 源Observable Op1(). // 第一个操作符 Op2(). // 第二个操作符 .. .. Opn().subscribe( on_datahandler, on_errorhandler, on_completehandler);

在操作符链式调用时，我们实际上是在组合函数。为了实现函数组合，一个函数的返回值类型应与组合链中下一个函数的参数类型兼容。操作符通常接受一个Observable作为参数，并返回另一个Observable，但也有返回非Observable值的情况，只有返回Observable的操作符才能参与操作符链式调用。

要编写一个可用于操作符链式调用的新操作符，最佳方法是将其作为observable<T>类型的方法添加。不过，编写能在不同上下文中运行的高质量操作符，最好交给RxCpp内部专家。另一种选择是使用RxCpp库中的lift<t>(...)操作符。

每个操作符实现都应具备无副作用的重要特性，即不应修