1 use {bytes::BytesMut, std::io}; 2 3 use futures::channel::mpsc::UnboundedReceiver; 4 use futures::channel::mpsc::UnboundedSender; 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 = UnboundedSender<io::Result<BytesMut>>; 12 pub type HttpResponseDataConsumer = UnboundedReceiver<io::Result<BytesMut>>; 13