Function kube_runtime::controller::trigger_with

pub fn trigger_with<T, K, I, S>(
    stream: S, 
    mapper: impl Fn(T) -> I
) -> impl Stream<Item = Result<ReconcileRequest<K>, S::Error>> where
    S: TryStream<Ok = T>,
    I: IntoIterator,
    I::Item: Into<ReconcileRequest<K>>,
    K: Resource, 

Helper for building custom trigger filters, see the implementations of trigger_self and trigger_owners for some examples.