code: public void subscribeTo(final K key, final Subscriber<V> subscriber, final Executor subscribeOn) {
          CompletableFuture.runAsync(() -> subscribeTo(key, subscriber), subscribeOn);
  
      }
docs: Subscribe asynchronously to a pipe
  
  <pre>
  {@code
  SeqSubscriber<String> reactiveSubscriber = SeqSubscriber.reactiveSubscriber();
  Queue<String> queue = new Queue();
  pipes.register("hello", queue);
  pipes.subscribeTo("hello",reactiveSubscriber,ForkJoinPool.commonPool());
  queue.offer("world");
  queue.close();
  
  assertThat(reactiveSubscriber.stream().findAny().getValue(),equalTo("world"));
  
  
  }
  </pre>
  
  
  @param key for registered simple-react async.Adapter
  @param subscriber Reactive Streams reactiveSubscriber for data on this pipe