public void publishTo ( final K key , final Publisher < V > publisher ) { registered . get ( key ) . fromStream ( Spouts . from ( publisher ) ) ; }
Synchronously publish data to the Adapter specified by the provided Key blocking the current thread