Home
last modified time | relevance | path

Searched refs:BytesMut (Results 1 – 25 of 59) sorted by relevance

123

/xiu/protocol/rtmp/src/cache/
H A Dmetadata.rs4 bytes::BytesMut,
9 chunk_body: BytesMut,
22 chunk_body: BytesMut::new(), in new()
27 pub fn save(&mut self, body: &BytesMut) { in save() argument
34 pub fn remove_set_data_frame(&mut self) -> Result<BytesMut, MetadataError> { in remove_set_data_frame() argument
40 Ok(BytesMut::from(right)) in remove_set_data_frame()
43 pub fn is_metadata(&mut self, body: BytesMut) -> bool { in is_metadata()
94 pub fn get_chunk_body(&self) -> BytesMut { in get_chunk_body() argument
H A Dmod.rs7 bytes::BytesMut,
28 video_seq: BytesMut,
30 audio_seq: BytesMut,
52 video_seq: BytesMut::new(), in new()
54 audio_seq: BytesMut::new(), in new()
64 pub fn save_metadata(&mut self, chunk_body: &BytesMut, timestamp: u32) { in save_metadata() argument
83 chunk_body: &BytesMut, in save_audio_data() argument
139 chunk_body: &BytesMut, in save_video_data() argument
/xiu/protocol/rtsp/src/rtp/rtcp/
H A Drtcp_app.rs6 use bytes::BytesMut;
25 pub name: BytesMut,
26 pub app_data: BytesMut,
29 impl Unmarshal<BytesMut, Result<Self, RtcpError>> for RtcpApp {
30 fn unmarshal(data: BytesMut) -> Result<Self, RtcpError> in unmarshal()
47 impl Marshal<Result<BytesMut, RtcpError>> for RtcpApp {
48 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal() argument
H A Drtcp_bye.rs6 use bytes::BytesMut;
26 pub reason: BytesMut,
29 impl Unmarshal<BytesMut, Result<Self, RtcpError>> for RtcpBye {
30 fn unmarshal(data: BytesMut) -> Result<Self, RtcpError> in unmarshal()
53 impl Marshal<Result<BytesMut, RtcpError>> for RtcpBye {
54 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal() argument
H A Drtcp_rr.rs6 use bytes::BytesMut;
38 impl Marshal<Result<BytesMut, RtcpError>> for ReportBlock {
39 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal() argument
61 impl Unmarshal<BytesMut, Result<Self, RtcpError>> for RtcpReceiverReport {
62 fn unmarshal(data: BytesMut) -> Result<Self, RtcpError> in unmarshal()
83 impl Marshal<Result<BytesMut, RtcpError>> for RtcpReceiverReport {
84 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal() argument
H A Drtcp_header.rs5 use bytes::BytesMut;
41 impl Marshal<Result<BytesMut, RtcpError>> for RtcpHeader {
42 fn marshal(&self) -> Result<BytesMut, RtcpError> { in marshal() argument
/xiu/protocol/rtmp/src/handshake/
H A Ddigest.rs7 bytes::BytesMut,
15 key: BytesMut,
19 pub fn new(data: BytesMut, key: BytesMut) -> Self { in new() argument
27 pub fn read_digest(&mut self) -> Result<(BytesMut, SchemaVersion), DigestError> { in read_digest() argument
46 pub fn generate_digest(&mut self) -> Result<BytesMut, DigestError> { in generate_digest() argument
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() argument
121 let mut rv = BytesMut::new(); in make_digest()
127 fn generate_and_validate(&mut self, version: SchemaVersion) -> Result<BytesMut, DigestError> { in generate_and_validate() argument
H A Dhandshake_server.rs7 bytes::BytesMut,
21 c1_bytes: BytesMut,
30 c1_digest: BytesMut,
41 c1_bytes: BytesMut::new(), in new()
93 c1_digest: BytesMut::new(), in new()
197 let mut key = BytesMut::new(); in read_c1()
227 let mut key = BytesMut::new(); in write_s1()
247 let mut key = BytesMut::new(); in write_s2()
254 let mut data: BytesMut = BytesMut::new(); in write_s2()
274 saved_data: BytesMut,
[all …]
H A Dhandshake_client.rs7 bytes::BytesMut,
20 s1_bytes: BytesMut,
27 reader: BytesReader::new(BytesMut::new()), in new()
29 s1_bytes: BytesMut::new(), in new()
/xiu/protocol/rtmp/src/utils/
H A Dprint.rs1 use bytes::BytesMut;
2 pub fn print(data: BytesMut) { in print() argument
16 pub fn print2(title: &str, data: BytesMut) { in print2() argument
30 pub fn printu8(data: BytesMut) { in printu8() argument
/xiu/protocol/httpflv/src/
H A Ddefine.rs3 {bytes::BytesMut, std::io},
10 pub type HttpResponseDataProducer = UnboundedSender<io::Result<BytesMut>>;
11 pub type HttpResponseDataConsumer = UnboundedReceiver<io::Result<BytesMut>>;
/xiu/library/bytesio/src/
H A Dbytes_reader.rs7 bytes::{BufMut, BytesMut},
13 buffer: BytesMut,
16 pub fn new(input: BytesMut) -> Self { in new()
55 ) -> Result<Cursor<BytesMut>, BytesReadError> { in read_bytes_cursor() argument
64 ) -> Result<Cursor<BytesMut>, BytesReadError> { in advance_bytes_cursor() argument
144 pub fn extract_remaining_bytes(&mut self) -> BytesMut { in extract_remaining_bytes() argument
147 pub fn get_remaining_bytes(&self) -> BytesMut { in get_remaining_bytes() argument
162 bytes_reader: BytesReader::new(BytesMut::default()), in new()
194 ) -> Result<Cursor<BytesMut>, BytesReadError> { in read_bytes_cursor() argument
202 ) -> Result<Cursor<BytesMut>, BytesReadError> { in advance_bytes_cursor() argument
[all …]
H A Dbytesio.rs7 use bytes::BytesMut;
25 async fn read(&mut self) -> Result<BytesMut, BytesIOError>; in read() argument
26 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError>; in read_timeout() argument
73 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError> { in read_timeout() argument
82 async fn read(&mut self) -> Result<BytesMut, BytesIOError> { in read() argument
85 let mut rv = BytesMut::new(); in read()
118 async fn read_timeout(&mut self, duration: Duration) -> Result<BytesMut, BytesIOError> { in read_timeout() argument
127 async fn read(&mut self) -> Result<BytesMut, BytesIOError> { in read() argument
H A Dbits_reader.rs4 bytes::BytesMut,
22 pub fn extend_data(&mut self, bytes: BytesMut) { in extend_data() argument
74 use bytes::BytesMut;
78 let mut bytes_reader = BytesReader::new(BytesMut::new()); in test_read_bit()
109 let mut bytes_reader = BytesReader::new(BytesMut::new()); in test_read_n_bits()
127 let mut bytes_reader = BytesReader::new(BytesMut::new()); in test_bits_aligment_8()
/xiu/library/container/mpegts/src/
H A Dcrc32.rs1 use bytes::BytesMut;
38 pub fn gen_crc32(crc: u32, buffer: BytesMut) -> u32 { in gen_crc32()
55 use bytes::BytesMut;
63 let mut payload = BytesMut::new(); in test_gen_crc32()
H A Dpmt.rs9 bytes::BytesMut,
19 pub program_info: BytesMut,
37 program_info: BytesMut::new(), in new()
60 pub fn write(&mut self, pmt: &Pmt) -> Result<BytesMut, MpegTsError> { in write() argument
/xiu/protocol/rtsp/src/rtp/
H A Dmod.rs11 use bytes::{BufMut, BytesMut};
26 pub header_extension_payload: BytesMut,
27 pub payload: BytesMut,
28 pub padding: BytesMut,
71 impl Marshal<Result<BytesMut, BytesWriteError>> for RtpPacket {
72 fn marshal(&self) -> Result<BytesMut, BytesWriteError> { in marshal() argument
H A Drtp_h264.rs17 use bytes::{BufMut, BytesMut};
143 async fn pack_nalu(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_nalu()
157 fu_buffer: BytesMut,
208 payload: BytesMut, in unpack_single() argument
212 let mut annexb_payload = BytesMut::new(); in unpack_single()
266 rtp_payload: BytesMut, in unpack_fu() argument
286 let mut payload = BytesMut::new(); in unpack_fu()
346 rtp_payload: BytesMut, in unpack_stap() argument
362 let mut payload = BytesMut::new(); in unpack_stap()
430 rtp_payload: BytesMut, in unpack_mtap() argument
[all …]
H A Drtp_h265.rs17 use bytes::{BufMut, BytesMut};
55 pub async fn pack_fu(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_fu()
123 pub async fn pack_single(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_single()
161 async fn pack_nalu(&mut self, nalu: BytesMut) -> Result<(), PackerError> { in pack_nalu()
175 fu_buffer: BytesMut,
221 fn unpack_single(&mut self, payload: BytesMut) -> Result<(), UnPackerError> { in unpack_single()
222 let mut annexb_payload = BytesMut::new(); in unpack_single()
259 fn unpack_ap(&mut self, rtp_payload: BytesMut) -> Result<(), UnPackerError> { in unpack_ap()
274 let mut payload = BytesMut::new(); in unpack_ap()
322 fn unpack_fu(&mut self, rtp_payload: BytesMut) -> Result<(), UnPackerError> { in unpack_fu()
[all …]
/xiu/protocol/rtmp/src/messages/
H A Ddefine.rs1 use {crate::amf0::define::Amf0ValueType, bytes::BytesMut};
25 raw_data: BytesMut,
44 data: BytesMut,
47 data: BytesMut,
/xiu/library/container/flv/src/
H A Ddemuxer.rs14 bytes::BytesMut,
79 pub data: BytesMut,
89 data: BytesMut::new(), in new()
99 pub data: BytesMut,
109 data: BytesMut::new(), in new()
128 data: BytesMut, in demux() argument
177 data: BytesMut, in demux() argument
217 pub fn new(data: BytesMut) -> Self { in new()
H A Ddemuxer_tag.rs3 bytes::BytesMut,
82 pub fn new(data: BytesMut) -> Self { in new()
104 pub fn get_remaining_bytes(&mut self) -> BytesMut { in get_remaining_bytes() argument
155 pub fn new(data: BytesMut) -> Self { in new()
192 pub fn get_remaining_bytes(&mut self) -> BytesMut { in get_remaining_bytes() argument
H A Dmpeg4_avc.rs4 bytes::BytesMut,
17 pub data: BytesMut,
24 data: BytesMut::new(), in new()
39 pub data: BytesMut,
46 data: BytesMut::new(), in new()
83 pub fn print(data: BytesMut) { in print() argument
231 ) -> Result<BytesMut, Mpeg4AvcHevcError> { in h264_mp4toannexb() argument
287 … pub fn nalus_to_mpeg4avc(&mut self, nalus: Vec<BytesMut>) -> Result<BytesMut, Mpeg4AvcHevcError> { in nalus_to_mpeg4avc() argument
299 pub fn decoder_configuration_record_save(&mut self) -> Result<BytesMut, Mpeg4AvcHevcError> { in decoder_configuration_record_save() argument
338 use bytes::BytesMut;
[all …]
H A Dflv_tag_header.rs9 bytes::BytesMut,
104 impl Marshal<Result<BytesMut, FlvMuxerError>> for AudioTagHeader {
105 fn marshal(&self) -> Result<BytesMut, FlvMuxerError> { in marshal() argument
197 impl Marshal<Result<BytesMut, FlvMuxerError>> for VideoTagHeader {
198 fn marshal(&self) -> Result<BytesMut, FlvMuxerError> { in marshal() argument
/xiu/protocol/rtsp/src/sdp/
H A Dfmtp.rs3 use bytes::{BufMut, BytesMut};
11 profile_level_id: BytesMut,
12 pub sps: BytesMut,
13 pub pps: BytesMut,
18 pub vps: BytesMut,
19 pub sps: BytesMut,
20 pub pps: BytesMut,
25 pub asc: BytesMut,
26 profile_level_id: BytesMut,
267 use bytes::BytesMut;
[all …]

123