Searched refs:TestingSubscriberEvent (Results 1 – 3 of 3) sorted by relevance
20 pub enum TestingSubscriberEvent { enum36 events: Vec<TestingSubscriberEvent>,76 pub fn take_events(&mut self) -> Vec<TestingSubscriberEvent> { in take_events() argument92 self.events.push(TestingSubscriberEvent::Subscribe); in on_subscribe()96 self.events.push(TestingSubscriberEvent::Next(frame)); in on_next()100 self.events.push(TestingSubscriberEvent::Error(error)); in on_error()104 self.events.push(TestingSubscriberEvent::Complete); in on_complete()
216 assert!(!matches!(events.last().unwrap(), TestingSubscriberEvent::Next(_))); in test_test_implementations_next()223 assert!(matches!(events.last().unwrap(), TestingSubscriberEvent::Next(_))); in test_test_implementations_next()238 assert!(matches!(events.last().unwrap(), TestingSubscriberEvent::Complete)); in test_test_implementations_complete()252 assert!(matches!(events.last().unwrap(), TestingSubscriberEvent::Error(_))); in test_test_implementations_error()
78 testing::{TestSubscriber, TestingSubscriberEvent},105 assert!(matches!(events.last().unwrap(), TestingSubscriberEvent::Next(_))); in test_send_next_frame()