public <T>PushableLazyFutureStream<T> futureStream(final LazyReact s){
  final Queue<T> q=createQueue();
  return new PushableLazyFutureStream<T>(q,s.fromStream(q.stream()));
}

public < T > PushableLazyFutureStream < T > futureStream ( final LazyReact s ) { final Queue < T > q = createQueue ( ) ; return new PushableLazyFutureStream < T > ( q , s . fromStream ( q . stream ( ) ) ) ; }
create a pushable lazyfuturestream using the supplied reactpool
