java RxJava自定义事件订阅服务器

Question

我有一个事件流，如RequestIssuseEvent、DataType1Event、DataType2Event等。我正在寻找一个操作符，它将捕获链中的事件并停止传播，否则将让事件继续抛出链的其余部分。（类似于subscriboThisTypeOfEvent（）

RxJava中是否有可以订阅自定义事件的操作符