Searched refs:SharedSubscriber (Results 1 – 3 of 3) sorted by relevance
31 pub struct SharedSubscriber<S: BufferSubscriber>(Arc<Mutex<SharedSubscriberInner<S>>>); struct38 impl<S: BufferSubscriber> SharedSubscriber<S> { implementation57 impl<S: BufferSubscriber> Clone for SharedSubscriber<S> { implementation63 impl<S: BufferSubscriber> BufferSubscriber for SharedSubscriber<S> { implementation
181 subscribers::{testing::*, SharedSubscriber},207 let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG)); in test_test_implementations_next()229 let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG)); in test_test_implementations_complete()243 let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG)); in test_test_implementations_error()
79 SharedSubscriber,95 let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG)); in test_send_next_frame()