code: @SuppressWarnings({ "unchecked", "rawtypes" })
      public Option<ReactiveSeq<V>> reactiveSeq(final K key) {
          return get(key).map(a -> a.stream());
      }
docs: Create a ReactiveSeq from the Adapter identified by the provided Key
  
  <pre>
  {@code
  Queue<String> q = new Queue<>();
  pipes.register("data-queue", q);
  pipes.push("data-queue", "world");
  
  on a separate thread
  ReactiveSeq<String> stream = pipes.reactiveSeq("data-queue");
  stream.forEach(System.out::println);
  "world"
  
  
  
  
  }
  </pre>
  
  
  @param key : Adapter identifier
  @return {@link ReactiveSeq} from selected Queue