在RxJava2中，Publisher和Flowable的Mutiny等价物是什么

Question

我想创建一个可以将对象推送到其中的buffering Multi。Multi用作REST端点的结果。

到目前为止，我所拥有的是：

    class MyService {
        private PublishProcessor<String> deviceStatusProcessor = PublishProcessor.create();
        private Flowable<String> deviceStatusQueue = Flowable.fromPublisher(deviceStatusProcessor);

        public void pushDeviceStatus(DeviceStatus deviceStatus) {
            deviceStatusProcessor.onNext(deviceStatus);
        }

        public Multi<String> getStream() {
            return Multi.createFrom().publisher(deviceStatusQueue);
        }
    }

然而，这段代码混合了RxJava和Mutiny。Publisher和Flowable的Mutiny等价物是什么？

Answer 1

看起来BoadcastProcessor等同于PublishProcessor。还有UnicastProcessor，它有缓冲，但只推送到一个订阅者。

Answer 2

这取决于你想做什么。

默认情况下，Multi不会发出任何东西，直到有一个订阅，在您的情况下，我相信这将是REST端点(每个接收到的请求一个订阅)。

UnicastProcessor以无界的方式存储所有发出的项。因此，请注意，如果有物品但没有人消费，如果不小心使用，可能会导致OutOfMemoryException。

BroadcastProcessor不存储项目，而是将它们分派给多个订阅者。