Use Overflow.BUFFER for PollableChPublisherAdapter

The `ReactiveStreamsConsumerTests.testReactiveStreamsConsumerPollableChannel()`
fails periodically.

Change the logic to rely on the `FluxSink.OverflowStrategy.BUFFER` for
possible future subscribers, meanwhile with `IGNORE` we just lose a message
altogether
This commit is contained in:
Artem Bilan
2020-01-22 15:47:00 -05:00
parent 9b7b0d91ac
commit 8bd9464b74

View File

@@ -93,8 +93,7 @@ public final class MessageChannelReactiveUtils {
&& (m = this.channel.receive()) != null) { // NOSONAR
sink.next((Message<T>) m);
}
}),
FluxSink.OverflowStrategy.IGNORE)
}))
.subscribeOn(Schedulers.elastic())
.subscribe(subscriber);
}