Home
last modified time | relevance | path

Searched defs:BytesMut (Results 1 – 25 of 37) sorted by relevance

12

/xiu/protocol/rtmp/src/handshake/
H A Ddigest.rs19 pub fn new(data: BytesMut, key: BytesMut) -> Self { in new()
27 pub fn read_digest(&mut self) -> Result<(BytesMut, SchemaVersion), DigestError> { in read_digest()
46 pub fn generate_digest(&mut self) -> Result<BytesMut, DigestError> { in generate_digest()
99 ) -> Result<(BytesMut, BytesMut, BytesMut), DigestError> { in cook_raw_message() argument
110 pub fn make_digest(&mut self, raw_message: Vec<u8>) -> Result<BytesMut, DigestError> { in make_digest()
127 fn generate_and_validate(&mut self, version: SchemaVersion) -> Result<BytesMut, DigestError> { in generate_and_validate()
/xiu/protocol/rtmp/src/utils/
H A Dprint.rs2 pub fn print(data: BytesMut) { in print()
16 pub fn print2(title: &str, data: BytesMut) { in print2()
30 pub fn printu8(data: BytesMut) { in printu8()
/xiu/protocol/rtmp/src/cache/
H A Dmetadata.rs27 pub fn save(&mut self, body: &BytesMut) { in save()
34 pub fn remove_set_data_frame(&mut self) -> Result<BytesMut, MetadataError> { in remove_set_data_frame()
94 pub fn get_chunk_body(&self) -> BytesMut { in get_chunk_body()
H A Dmod.rs64 pub fn save_metadata(&mut self, chunk_body: &BytesMut, timestamp: u32) { in save_metadata()
83 chunk_body: &BytesMut, in save_audio_data()
139 chunk_body: &BytesMut, in save_video_data()
/xiu/library/bytesio/src/
H A Dbytesio.rs25 async fn read(&mut self) -> Result<BytesMut, BytesIOError>; in read()
26 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError>; in read_timeout()
73 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError> { in read_timeout()
82 async fn read(&mut self) -> Result<BytesMut, BytesIOError> { in read()
118 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError> { in read_timeout()
127 async fn read(&mut self) -> Result<BytesMut, BytesIOError> { in read()
H A Dbytes_reader.rs32 pub fn read_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in read_bytes()
41 pub fn advance_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in advance_bytes()
55 ) -> Result<Cursor<BytesMut>, BytesReadError> { in read_bytes_cursor()
64 ) -> Result<Cursor<BytesMut>, BytesReadError> { in advance_bytes_cursor()
144 pub fn extract_remaining_bytes(&mut self) -> BytesMut { in extract_remaining_bytes()
147 pub fn get_remaining_bytes(&self) -> BytesMut { in get_remaining_bytes()
181 pub async fn read_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in read_bytes()
186 pub async fn advance_bytes(&mut self, bytes_num: usize) -> Result<BytesMut, BytesReadError> { in advance_bytes()
194 ) -> Result<Cursor<BytesMut>, BytesReadError> { in read_bytes_cursor()
202 ) -> Result<Cursor<BytesMut>, BytesReadError> { in advance_bytes_cursor()
/xiu/protocol/rtmp/src/remuxer/
H A Drtsp2rtmp.rs225 audio_data: &mut BytesMut, in on_rtsp_audio()
260 nalus: &mut BytesMut, in on_rtsp_video()
342 fn gen_rtmp_meta_data(&self, width: u32, height: u32) -> Result<BytesMut, RtmpRemuxerError> { in gen_rtmp_meta_data()
358 sps: BytesMut, in gen_rtmp_video_seq_header()
359 pps: BytesMut, in gen_rtmp_video_seq_header()
362 ) -> Result<BytesMut, RtmpRemuxerError> { in gen_rtmp_video_seq_header()
395 nalus: Vec<BytesMut>, in gen_rtmp_video_frame_data()
397 ) -> Result<BytesMut, RtmpRemuxerError> { in gen_rtmp_video_frame_data()
/xiu/protocol/rtmp/src/session/
H A Dcommon.rs110 pub async fn send_audio(&mut self, data: BytesMut, timestamp: u32) -> Result<(), SessionError> { in send_audio()
128 pub async fn send_video(&mut self, data: BytesMut, timestamp: u32) -> Result<(), SessionError> { in send_video()
148 data: BytesMut, in send_metadata()
170 data: &mut BytesMut, in on_video_data()
197 data: &mut BytesMut, in on_audio_data()
224 data: &mut BytesMut, in on_meta_data()
455 chunk_body: &BytesMut, in save_video_data()
466 chunk_body: &BytesMut, in save_audio_data()
475 pub async fn save_metadata(&self, chunk_body: &BytesMut, timestamp: u32) { in save_metadata()
/xiu/protocol/rtsp/src/
H A Drtsp_utils.rs11 pub fn print(title: &str, data: BytesMut) { in print()
/xiu/protocol/rtsp/src/rtp/
H A Drtp_h264.rs124 async fn pack(&mut self, nalus: &mut BytesMut, timestamp: u32) -> Result<(), PackerError> { in pack()
208 payload: BytesMut, in unpack_single()
266 rtp_payload: BytesMut, in unpack_fu()
346 rtp_payload: BytesMut, in unpack_stap()
430 rtp_payload: BytesMut, in unpack_mtap()
H A Dutils.rs50 async fn pack(&mut self, nalus: &mut BytesMut, timestamp: u32) -> Result<(), PackerError>; in pack()
82 nalus: &mut BytesMut, in split_annexb_and_process()
H A Drtp_header.rs66 fn marshal(&self) -> Result<BytesMut, BytesWriteError> { in marshal()
/xiu/library/container/mpegts/src/
H A Dts.rs61 pub fn get_data(&mut self) -> BytesMut { in get_data()
71 payload: BytesMut, in write()
138 payload: BytesMut, in write_ts_header_for_pat_pmt()
368 extra_data: BytesMut, in pmt_add_stream()
H A Dpat.rs52 pub fn write(&mut self, pat: Pat) -> Result<BytesMut, MpegTsError> { in write()
/xiu/protocol/hls/src/
H A Dtest_flv2hls.rs15 pub fn print(data: BytesMut) { in print()
/xiu/protocol/rtsp/src/rtp/rtcp/
H A Drtcp_rr.rs39 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
84 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
H A Drtcp_app.rs48 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
H A Drtcp_bye.rs54 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
H A Drtcp_header.rs42 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
H A Drtcp_sr.rs83 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal()
/xiu/protocol/rtmp/src/amf0/
H A Damf0_writer.rs114 pub fn extract_current_bytes(&mut self) -> BytesMut { in extract_current_bytes()
118 pub fn get_current_bytes(&mut self) -> BytesMut { in get_current_bytes()
/xiu/library/container/flv/src/
H A Dmpeg4_avc.rs83 pub fn print(data: BytesMut) { in print()
231 ) -> Result<BytesMut, Mpeg4AvcHevcError> { in h264_mp4toannexb()
287 … pub fn nalus_to_mpeg4avc(&mut self, nalus: Vec<BytesMut>) -> Result<BytesMut, Mpeg4AvcHevcError> { in nalus_to_mpeg4avc()
299 pub fn decoder_configuration_record_save(&mut self) -> Result<BytesMut, Mpeg4AvcHevcError> { in decoder_configuration_record_save()
H A Dflv_tag_header.rs105 fn marshal(&self) -> Result<BytesMut, FlvMuxerError> { in marshal()
198 fn marshal(&self) -> Result<BytesMut, FlvMuxerError> { in marshal()
H A Ddemuxer_tag.rs104 pub fn get_remaining_bytes(&mut self) -> BytesMut { in get_remaining_bytes()
192 pub fn get_remaining_bytes(&mut self) -> BytesMut { in get_remaining_bytes()
H A Ddemuxer.rs128 data: BytesMut, in demux()
177 data: BytesMut, in demux()

12