Searched refs:STREAM_CONFIG (Results 1 – 4 of 4) sorted by relevance
184 const STREAM_CONFIG: StreamConfig = StreamConfig { constant196 STREAM_CONFIG in make_frame()207 let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG)); in test_test_implementations_next()208 let mut publisher = TestPublisher::new(STREAM_CONFIG); in test_test_implementations_next()229 let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG)); in test_test_implementations_complete()230 let mut publisher = TestPublisher::new(STREAM_CONFIG); in test_test_implementations_complete()243 let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG)); in test_test_implementations_error()244 let mut publisher = TestPublisher::new(STREAM_CONFIG); in test_test_implementations_error()
84 const STREAM_CONFIG: StreamConfig = StreamConfig { constant95 let subscriber = SharedSubscriber::new(TestSubscriber::new(STREAM_CONFIG)); in test_send_next_frame()97 let mut buffer_pool_publisher = BufferPoolPublisher::new(STREAM_CONFIG, 1).unwrap(); in test_send_next_frame()
110 const STREAM_CONFIG: StreamConfig = StreamConfig { constant121 let mut buffer_pool = BufferPool::new(1, STREAM_CONFIG).unwrap(); in buffer_pool_next_buffer()130 let mut buffer_pool = BufferPool::new(1, STREAM_CONFIG).unwrap(); in drop_buffer_returns_to_pool()
63 const STREAM_CONFIG: StreamConfig = StreamConfig { constant74 let hardware_buffer = STREAM_CONFIG.create_hardware_buffer().unwrap(); in test_get_buffer_id()