| /xiu/protocol/rtmp/src/cache/ |
| H A D | gop.rs | 1 use {std::collections::VecDeque, streamhub::define::FrameData};
4 datas: Vec<FrameData>,
18 fn save_frame_data(&mut self, data: FrameData) { in save_frame_data() argument
22 pub fn get_frame_data(self) -> Vec<FrameData> { in get_frame_data() argument
55 pub fn save_frame_data(&mut self, data: FrameData, is_key_frame: bool) { in save_frame_data() argument
|
| H A D | mod.rs | 12 streamhub::define::FrameData,
69 pub fn get_metadata(&self) -> Option<FrameData> { in get_metadata() argument
72 Some(FrameData::MetaData { in get_metadata()
86 let channel_data = FrameData::Audio { in save_audio_data()
117 pub fn get_audio_seq(&self) -> Option<FrameData> { in get_audio_seq() argument
119 return Some(FrameData::Audio { in get_audio_seq()
127 pub fn get_video_seq(&self) -> Option<FrameData> { in get_video_seq() argument
129 return Some(FrameData::Video { in get_video_seq()
142 let channel_data = FrameData::Video { in save_video_data()
|
| /xiu/protocol/httpflv/src/ |
| H A D | httpflv.rs | 14 FrameData, FrameDataReceiver, NotifyInfo, StreamHubEvent, StreamHubEventSender,
102 pub fn write_flv_tag(&mut self, channel_data: FrameData) -> Result<(), HttpFLvError> { in write_flv_tag()
104 FrameData::Audio { timestamp, data } => (data, timestamp, tag_type::AUDIO), in write_flv_tag()
105 FrameData::Video { timestamp, data } => (data, timestamp, tag_type::VIDEO), in write_flv_tag()
106 FrameData::MetaData { timestamp, data } => { in write_flv_tag()
|
| /xiu/protocol/hls/src/ |
| H A D | flv_data_receiver.rs | 12 FrameData, FrameDataReceiver, NotifyInfo, StreamHubEvent, StreamHubEventSender,
68 FrameData::Audio { timestamp, data } => FlvData::Audio { timestamp, data }, in receive_flv_data()
69 FrameData::Video { timestamp, data } => FlvData::Video { timestamp, data }, in receive_flv_data()
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | rtp_h264.rs | 21 use streamhub::define::FrameData;
216 f(FrameData::Video { in unpack_single()
291 f(FrameData::Video { in unpack_fu()
366 f(FrameData::Video { in unpack_stap()
460 f(FrameData::Video { in unpack_mtap()
|
| H A D | rtp_h265.rs | 21 use streamhub::define::FrameData;
227 f(FrameData::Video { in unpack_single()
279 f(FrameData::Video { in unpack_ap()
348 f(FrameData::Video { in unpack_fu()
|
| H A D | rtp_aac.rs | 20 use streamhub::define::FrameData;
148 f(FrameData::Audio { in unpack()
|
| H A D | utils.rs | 13 use streamhub::define::FrameData;
26 pub type OnFrameFn = Box<dyn Fn(FrameData) -> Result<(), UnPackerError> + Send + Sync>;
|
| /xiu/protocol/rtmp/src/session/ |
| H A D | common.rs | 25 FrameData, FrameDataReceiver, FrameDataSender, InformationSender, NotifyInfo,
83 FrameData::Audio { timestamp, data } => { in send_channel_data()
86 FrameData::Video { timestamp, data } => { in send_channel_data()
89 FrameData::MetaData { timestamp, data } => { in send_channel_data()
173 let channel_data = FrameData::Video { in on_video_data()
200 let channel_data = FrameData::Audio { in on_audio_data()
227 let channel_data = FrameData::MetaData { in on_meta_data()
|
| /xiu/library/streamhub/src/ |
| H A D | lib.rs | 16 DataReceiver, DataSender, FrameData, FrameDataSender, Information, PubSubInfo,
68 FrameData::MetaData { in receive_frame_data_loop()
72 FrameData::Audio { timestamp, data } => { in receive_frame_data_loop()
73 let data = FrameData::Audio { in receive_frame_data_loop()
86 FrameData::Video { timestamp, data } => { in receive_frame_data_loop()
87 let data = FrameData::Video { in receive_frame_data_loop()
99 FrameData::MediaInfo { media_info: _ } => {} in receive_frame_data_loop()
|
| H A D | define.rs | 121 pub enum FrameData { enum
143 pub type FrameDataSender = mpsc::UnboundedSender<FrameData>;
144 pub type FrameDataReceiver = mpsc::UnboundedReceiver<FrameData>;
|
| /xiu/protocol/rtmp/src/remuxer/ |
| H A D | rtsp2rtmp.rs | 26 FrameData, FrameDataReceiver, NotifyInfo, StreamHubEvent, StreamHubEventSender,
180 FrameData::Audio { in receive_rtsp_data()
184 FrameData::Video { in receive_rtsp_data()
190 FrameData::MediaInfo { media_info } => { in receive_rtsp_data()
|
| /xiu/protocol/rtsp/src/session/ |
| H A D | mod.rs | 51 FrameData, Information, InformationSender, NotifyInfo, PublishType, PublisherInfo,
302 move |msg: FrameData| -> Result<(), UnPackerError> { in handle_announce()
486 FrameData::Audio { in handle_play()
499 FrameData::Video { in handle_play()
754 let frame_data = FrameData::Video { in send_prior_data()
771 let frame_data = FrameData::Video { in send_prior_data()
782 let frame_data = FrameData::Audio { in send_prior_data()
797 if let Err(err) = sender.send(FrameData::MediaInfo { in send_prior_data()
|