Searched refs:buffer_pool_publisher (Results 1 – 2 of 2) sorted by relevance
97 let mut buffer_pool_publisher = BufferPoolPublisher::new(STREAM_CONFIG, 1).unwrap(); in test_send_next_frame() localVariable98 buffer_pool_publisher.subscribe(subscriber.clone()); in test_send_next_frame()102 assert!(buffer_pool_publisher.send_next_frame(1)); in test_send_next_frame()106 assert_eq!(buffer_pool_publisher.subscription.pending_requests(), 0); in test_send_next_frame()
17 mod buffer_pool_publisher; module20 pub use buffer_pool_publisher::*;