Теперь StreaminApiContext завязан на интерфейсе Reactive Streams. Реализация на Java 8 имплементирует асинхронный вариант org.reactivestreams.Producer. Асинхронность можно контролировать указанием нужного экземпляра java.util.concurrent.Executor при создании объекта OpenApi/SandboxOpenApi.
В примере показано использование новой реализации с применением org.reactivestreams.example.unicast.AsyncSubscriber в качестве имплементации org.reactivestreams.Subscriber.
Теперь StreaminApiContext завязан на интерфейсе Reactive Streams. Реализация на Java 8 имплементирует асинхронный вариант
org.reactivestreams.Producer. Асинхронность можно контролировать указанием нужного экземпляраjava.util.concurrent.Executorпри создании объектаOpenApi/SandboxOpenApi. В примере показано использование новой реализации с применениемorg.reactivestreams.example.unicast.AsyncSubscriberв качестве имплементацииorg.reactivestreams.Subscriber.