code: @SuppressWarnings({ "unchecked", "rawtypes" })
      public Option<FutureStream<V>> futureStream(final K key, final LazyReact builder) {
  
          return get(key).map(a -> builder.fromStream(a.stream()));
      }
docs: Create a FutureStream using the provided LazyReact futureStream builder
  from the Adapter identified by the provided Key
  
  <pre>
  {@code
  Pipes<String, Integer> bus = Pipes.of();
  bus.register("reactor", QueueFactories.<Integer>boundedNonBlockingQueue(1000)
  .build());
  
  bus.publishTo("reactor",ReactiveSeq.of(10,20,30));
  
  bus.close("reactor");
  
  
  on another thread
  List<String> res =  bus.futureStream("reactor", new LazyReact(10,10))
  .getValue()
  .map(i->"fan-out to handle blocking I/O:" + Thread.currentThread().getId() + ":"+i)
  .toList();
  System.out.println(res);
  
  assertThat(res.size(),equalTo(3));
  
  
  }
  </pre>
  
  
  @param key : Adapter identifier
  @param builder LazyReact futureStream builder
  @return LazyFutureStream from selected Queue