1 use { 2 bytes::BytesMut, 3 tokio::sync::{broadcast, mpsc, oneshot}, 4 std::io, 5 }; 6 7 use futures::channel::mpsc::UnboundedReceiver; 8 use futures::channel::mpsc::UnboundedSender; 9 10 pub mod tag_type { 11 pub const AUDIO: u8 = 8; 12 pub const VIDEO: u8 = 9; 13 pub const SCRIPT_DATA_AMF: u8 = 18; 14 } 15 pub type HttpResponseDataProducer = UnboundedSender<io::Result<BytesMut>>; 16 pub type HttpResponseDataConsumer = UnboundedReceiver<io::Result<BytesMut>>; 17