Searched defs:SharedSubscriberInner (Results 1 – 1 of 1) sorted by relevance
33 struct SharedSubscriberInner<S: BufferSubscriber> { struct41 Self(Arc::new(Mutex::new(SharedSubscriberInner { subscriber, is_subscribed: false }))) in new() argument