让我们说我正以非常具体的方式观察一个观察者.
resultObservable = anotherObservable.filter(~Filter code~).take(15);
我想创建一个自定义运算符,它结合了两个预定义的运算符,如filter和take.这样表现得像
resultObservable = anotherObservable.lift(new FilterAndTake(15));
要么...
resultObservable = anotherObservable.FilterAndTake(15);
到目前为止,我很乐意编写一个可以执行此操作的特定操作符.我可以解除那个操作员.
但是,鉴于我目前对rx java的知识有限,这将涉及每次我需要在自定义运算符中使用它时重写take和filter功能.
这样做很好,但我宁愿重新使用由开源社区维护的预先存在的运营商,以及我创建的回收运营商.
还有一些东西告诉我,我对运营商和订户缺乏足够的了解.
有人可以推荐不是rx-java文档的教程吗？
我这样说是因为,虽然文档解释了一般概念,但它隔离了它们功能的概念和一般上下文,没有任何例子来激发RX java的更强大的应用程序.
所以特别是
我正在尝试将自定义数据流封装到代表性运算符中.这个功能是否存在？