Function rxrust::impl_helper::impl_shared::actual_subscribe

pub fn actual_subscribe<S, O>(s: S, o: O) -> S::Unsub where
    S: SharedObservable,
    O: Observer<Item = S::Item, Err = S::Err> + Send + Sync + 'static,