code: public void subscribeTo(final K key, final Subscriber<V> subscriber) {
          registered.get(key)
                    .stream()
                    .subscribe(subscriber);
  
      }
docs: Subscribe synchronously to a pipe
  
  @param key for registered simple-react async.Adapter
  @param subscriber Reactive Streams reactiveSubscriber for data on this pipe