@ SuppressWarnings ( { "unchecked" , "rawtypes" } ) public Option < V > oneValue ( final K key ) { final ValueSubscriber < V > sub = ValueSubscriber . subscriber ( ) ; return get ( key ) . peek ( a -> a . stream ( ) . subscribe ( sub ) ) . flatMap ( a -> sub . toMaybe ( ) ) ; }
Extract one value from the selected pipe if it exists