What is back-pressure? Backpressure or the ability for the consumer to signal the producer that the rate of emission is too high – Reactor Reference When we are talking about backpressure we have to separate sources/publishers into two groups: the ones that respect the demand from the subscriber, and those that ignore it. Generally hot … Read more
To set the read and connect timeout I use the method below, because the SO_TIMEOUT option is not available for channels using NIO (and giving the warning Unknown channel option ‘SO_TIMEOUT’ for channel ‘[id: 0xa716fcb2]’) ReactorClientHttpConnector connector = new ReactorClientHttpConnector( options -> options.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 2000) .compression(true) .afterNettyContextInit(ctx -> { ctx.addHandlerLast(new ReadTimeoutHandler(5000, TimeUnit.MILLISECONDS)); })); return WebClient.builder() .clientConnector(connector) … Read more
There are a couple of ways that could be considered as a convenient way of exception throwing: Handle your element using Flux/Mono.handle One of the way that could simplify handling of an element which may result in an error or empty stream is operator handle. The following code shows how we can use it in … Read more