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