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