import org.springframework.web.reactive.function.client.WebClientResponseException;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
import reactor.util.retry.Retry;
import java.nio.charset.Charset;
@Slf4j
-public class TestWriter implements Runnable
+public class TestWriter
{
- @Override
- public void run()
+ public Mono<Void> run()
{
- Flux
+ return Flux
.fromIterable((Iterable<Integer>) () -> new Iterator<>()
{
private int i = 0;
user,
e.getResponseBodyAsString(Charset.defaultCharset()));
})
- .then()
- .block();
+ .parallel()
+ .runOn(Schedulers.parallel())
+ .then();
}
private Mono<MessageTo> sendMessage(