Решение задачи с использованием ByteArrayInputStream/ByteArrayOutputStream:
src/test/java/org/example/ByteArrayTest.java
Решение задачи с использованием spring-webflux:
src/test/java/org/example/SpringAndFluxTest.java
Решение задачи с использованием библиотеки ReactiveX:
src/test/java/org/example/ReactivexTest.java