pub fn trigger_owners<KOwner, S>(
stream: S,
owner_type: <KOwner as Resource>::DynamicType,
child_type: <<S as TryStream>::Ok as Resource>::DynamicType,
) -> impl Stream<Item = Result<ReconcileRequest<KOwner>, <S as TryStream>::Error>>
Expand description
Enqueues any owners of type KOwner
for reconciliation