hedera-mirror-node
hedera-mirror-node copied to clipboard
Replace use of deprecated DirectProcessor
Problem
SharedTopicListener uses reactor.core.publisher.DirectProcessor which is deprecated.
Solution
Update SharedTopicListener to use Project Reactor Sinks. Make sure that the Sink implementation is as performant as the DirectProcesser.
Alternatives
No response