Каковы мятежные эквиваленты для Publisher и Flowable в RxJava2

Question

Я хочу создать буфер Multi, к которому я могу добавить sh объектов. 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);
        }
    }

Однако этот код смешивает Rx Java и Mutiny. Каковы мятежные эквиваленты для издателя и текучих?

Answer 1

Кажется, что BoadcastProcessor эквивалентно PublishProcessor. Существует также UnicastProcessor , который имеет буферизацию, но передает только одному подписчику.