rxrs
pub fn create<'a: 'b, 'b, V: 'a, F, R>(sub: F) -> LocalObservable<'a, V, F, R> where F: 'b + FnMut(Mss<No, &(Observer<V> + 'a)>) -> R, R: IntoSubRef<No> + 'a,