public ReactiveTask requestAsync ( final long n ) { return withSubscriptionAndTask ( subscriptionAndTask . map2 ( c -> CompletableFuture . runAsync ( ( ) -> subscriptionAndTask . _1 ( ) . join ( ) . request ( n ) , exec ) ) ) ; }
Asyncrhonously request more elements from the Stream