public < T > PushableFutureStream < T > futureStream ( final LazyReact s ) { final Queue < T > q = createQueue ( ) ; return new PushableFutureStream < T > ( q , s . fromStream ( q . stream ( ) ) ) ; }
Create a pushable FutureStream using the supplied ReactPool