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