在RxJava2中，Publisher和Flowable的Mutiny对应的是什么？

Question

我想创建一个缓冲的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。还有 单播处理器，它有缓冲功能，但只推送给一个用户。