1 use { 2 bytes::BytesMut, 3 tokio::sync::{broadcast, mpsc, oneshot}, 4 }; 5 6 pub mod tag_type { 7 pub const audio: u8 = 8; 8 pub const video: u8 = 9; 9 pub const script_data_amf: u8 = 18; 10 } 11 pub type HttpResponseDataProducer = mpsc::UnboundedSender<BytesMut>; 12 pub type HttpResponseDataConsumer = mpsc::UnboundedReceiver<BytesMut>; 13