How to make Reactor TestPublisher return Error for the first subscription, but emit value for the next one to test Retries?
I want to write a unit test, that ensures some retry mechanism is in place, and thus the code under test can handle a when the Publisher emits an error the first time it is subscribed to.
Close the flux immediately if the backpressureBuffer is overflow
I have a multicast sink with a directBestEffort strategy in which I put various events.