code: public <U> FutureStream<U> fromAdapter(final Adapter<U> adapter) {
          final Subscription sub = new Subscription();
          return new FutureStreamImpl(this,()->adapter.stream(sub)){
              @Override
              public ReactiveSeq<U> stream() {
                  return (ReactiveSeq<U>)adapter.stream(sub);
              }
          };
  
  
      }
docs: Generate a FutureStream from the data flowing into the prodiced Adapter
  <pre>
  {@code
  
  Topic<Integer> topic = new Topic<>();
  
  new LazyReact(10,10).fromAdapter(topic)
  .forEach(this::process);
  
  //on anther thread
  topic.offer(100);
  topic.offer(200);
  
  }
  </pre>
  
  
  @param adapter Adapter to construct FutureStream from
  @return FutureStream