code: public void publishTo(final K key, final Publisher<V> publisher) {
          registered.get(key).fromStream(Spouts.from(publisher));
      }
docs: Synchronously publish data to the Adapter specified by the provided Key, blocking the current thread
  
  @param key for registered cylops-react async.Adapter
  @param publisher Reactive Streams publisher  to push data onto this pipe