public void subscribeTo(final K key,final Subscriber<V> subscriber,final Executor subscribeOn){
  CompletableFuture.runAsync(null,subscribeOn);
}

public void subscribeTo ( final K key , final Subscriber < V > subscriber , final Executor subscribeOn ) { CompletableFuture . runAsync ( null , subscribeOn ) ; }
subscribe asynchronously to a pipe
