run_subscription_with

danceinterpreter_rs::async_utils

Function run_subscription_with 

Source 
pub fn run_subscription_with<T, D, S>(
    data: D,
    builder: fn(&D) -> S,
) -> Subscription<T>
where
    D: Hash + 'static,
    S: Stream<Item = T> + MaybeSend + 'static,
    T: 'static,