Function rxrs::create_sso

pub fn create_sso<'a, V, F, R>(sub: F) -> SendSyncObserverObservable<V, F, R> where
    F: Send + Sync + Fn(Mss<Yes, Box<Observer<V> + 'static>>) -> R,
    R: IntoSubRef<Yes>,