62     fn subscribe(&mut self, subscriber: impl BufferSubscriber + 'static);  in subscribe()
207         let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG));  in test_test_implementations_next()  localVariable
210         publisher.subscribe(subscriber.clone());  in test_test_implementations_next()
211         assert!(subscriber.map_inner(|s| s.has_subscription()));  in test_test_implementations_next()
215         let events = subscriber.map_inner_mut(|s| s.take_events());  in test_test_implementations_next()
218         subscriber.map_inner(|s| s.request(1));  in test_test_implementations_next()
222         let events = subscriber.map_inner_mut(|s| s.take_events());  in test_test_implementations_next()
229         let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG));  in test_test_implementations_complete()  localVariable
232         publisher.subscribe(subscriber.clone());  in test_test_implementations_complete()
233         assert!(subscriber.map_inner(|s| s.has_subscription()));  in test_test_implementations_complete()
237         let events = subscriber.map_inner_mut(|s| s.take_events());  in test_test_implementations_complete()
243         let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG));  in test_test_implementations_error()  localVariable
246         publisher.subscribe(subscriber.clone());  in test_test_implementations_error()
247         assert!(subscriber.map_inner(|s| s.has_subscription()));  in test_test_implementations_error()
251         let events = subscriber.map_inner_mut(|s| s.take_events());  in test_test_implementations_error()