如何为响应式Spring Integration流编写过滤器？

我在集成流中使用RSocket作为InboundGateway，采用REQUEST_CHANNEL交互模型，它会发出业务对象的Flux。我可以使用RSocket OutboundGateways对这些对象进行“装饰”，但无法在IntegrationFlow中添加过滤器或路由器步骤。GenericSelector需要返回布尔值，因此无法用于Flux；recipientFlow也是类似情况。我已搜索多日但毫无头绪。是否有该用例的示例？或者我需要使用split()来拆分到单个对象？感谢提供任何提示！（由于对象数量庞大，我希望构建全响应式流。）

更新 #

经过一番摸索和资料研读，我开始意识到，只要流的首尾都是阻塞操作（Terradata -> 流 -> Oracle），构建响应式流就会非常困难。因此我暂时撤回该问题，转而探索以常规阻塞方式运行流的高效方案。我希望很快能回归响应式流的开发。再次感谢各位的提示！

更新2 #

我已回归响应式流开发。现在我对响应式流的意义有了更清晰的理解，同时发现对于包含50万+事件/对象的大型Flux，过滤器无法正常工作，必须将其实现为处理器。目前CPU和内存占用以及处理速度表现出色。

内容的提问来源于stack exchange，提问作者ltuska