| /xiu/library/bytesio/src/ |
| H A D | bits_reader.rs | 3 super::bytes_reader::BytesReader, 8 reader: BytesReader, 14 pub fn new(reader: BytesReader) -> Self { in new() 73 use super::BytesReader; 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()
|
| H A D | bytes_reader.rs | 12 pub struct BytesReader { struct 15 impl BytesReader { argument 152 pub bytes_reader: BytesReader, 162 bytes_reader: BytesReader::new(BytesMut::default()), in new() 246 use super::BytesReader; 253 let reader = Rc::new(RefCell::new(BytesReader::new(BytesMut::new()))); in test_rc_refcell() 268 pub reader: Rc<RefCell<BytesReader>>, 272 pub fn new(reader: Rc<RefCell<BytesReader>>) -> Self { in new() 287 let reader = Rc::new(RefCell::new(BytesReader::new(BytesMut::new()))); in test_struct_rc_refcell()
|
| /xiu/library/container/flv/src/ |
| H A D | demuxer_tag.rs | 4 bytesio::bytes_reader::BytesReader, 77 bytes_reader: BytesReader, 84 bytes_reader: BytesReader::new(data), in new() 150 bytes_reader: BytesReader, 157 bytes_reader: BytesReader::new(data), in new()
|
| H A D | flv_tag_header.rs | 10 bytesio::bytes_reader::BytesReader, 83 impl Unmarshal<&mut BytesReader, Result<Self, FlvDemuxerError>> for AudioTagHeader { 84 fn unmarshal(reader: &mut BytesReader) -> Result<Self, FlvDemuxerError> in unmarshal() 161 impl Unmarshal<&mut BytesReader, Result<Self, FlvDemuxerError>> for VideoTagHeader { 162 fn unmarshal(reader: &mut BytesReader) -> Result<Self, FlvDemuxerError> in unmarshal()
|
| H A D | demuxer.rs | 15 bytesio::bytes_reader::BytesReader, 130 let mut reader = BytesReader::new(data); in demux() 179 let mut reader = BytesReader::new(data); in demux() 213 bytes_reader: BytesReader, 219 bytes_reader: BytesReader::new(data), in new()
|
| H A D | mpeg4_avc.rs | 5 bytesio::{bytes_reader::BytesReader, bytes_writer::BytesWriter}, 147 bytes_reader: &mut BytesReader, in decoder_configuration_record_load() argument 176 let mut sps_reader = BytesReader::new(sps_data.clone().data); in decoder_configuration_record_load() 230 bytes_reader: &mut BytesReader, in h264_mp4toannexb() argument 264 …pub fn read_nalu_size(&mut self, bytes_reader: &mut BytesReader) -> Result<u32, Mpeg4AvcHevcError>… in read_nalu_size() 339 use bytesio::{bytes_reader::BytesReader, bytes_writer::BytesWriter}; 346 let mut bytes_reader = BytesReader::new(b); in test_bytes_to_bigend()
|
| H A D | mpeg4_hevc.rs | 1 use {super::errors::Mpeg4AvcHevcError, byteorder::BigEndian, bytesio::bytes_reader::BytesReader}; 33 bytes_reader: &mut BytesReader, in decoder_configuration_record_load() argument
|
| /xiu/protocol/rtmp/src/protocol_control_messages/ |
| H A D | reader.rs | 4 bytesio::bytes_reader::BytesReader, 8 pub reader: BytesReader, 12 pub fn new(reader: BytesReader) -> Self { in new()
|
| /xiu/protocol/rtmp/src/netconnection/ |
| H A D | reader.rs | 3 bytesio::bytes_reader::BytesReader, 8 reader: BytesReader,
|
| /xiu/protocol/rtsp/src/rtp/rtcp/ |
| H A D | rtcp_header.rs | 6 use bytesio::bytes_reader::BytesReader; 23 impl Unmarshal<&mut BytesReader, Result<Self, RtcpError>> for RtcpHeader { 24 fn unmarshal(reader: &mut BytesReader) -> Result<Self, RtcpError> in unmarshal()
|
| H A D | rtcp_rr.rs | 7 use bytesio::bytes_reader::BytesReader; 21 impl Unmarshal<&mut BytesReader, Result<Self, RtcpError>> for ReportBlock { 22 fn unmarshal(reader: &mut BytesReader) -> Result<Self, RtcpError> in unmarshal() 66 let mut reader = BytesReader::new(data); in unmarshal()
|
| H A D | rtcp_sr.rs | 8 use bytesio::bytes_reader::BytesReader; 58 impl Unmarshal<&mut BytesReader, Result<Self, RtcpError>> for RtcpSenderReport { 59 fn unmarshal(reader: &mut BytesReader) -> Result<Self, RtcpError> in unmarshal()
|
| H A D | rtcp_app.rs | 7 use bytesio::bytes_reader::BytesReader; 34 let mut reader = BytesReader::new(data); in unmarshal()
|
| H A D | rtcp_bye.rs | 7 use bytesio::bytes_reader::BytesReader; 34 let mut reader = BytesReader::new(data); in unmarshal()
|
| /xiu/protocol/rtmp/src/user_control_messages/ |
| H A D | reader.rs | 5 bytesio::bytes_reader::BytesReader, 9 pub reader: BytesReader, 13 pub fn new(reader: BytesReader) -> Self { in new()
|
| /xiu/protocol/rtsp/src/ |
| H A D | rtsp_track.rs | 8 use bytesio::bytes_reader::BytesReader; 64 let mut reader = BytesReader::new(BytesMut::new()); in rtp_receive_loop() 87 let mut reader = BytesReader::new(BytesMut::new()); in rtcp_receive_loop() 117 pub async fn on_rtp(&mut self, reader: &mut BytesReader) -> Result<(), UnPackerError> { in on_rtp() 123 reader: &mut BytesReader, in on_rtcp() argument
|
| /xiu/protocol/rtsp/src/rtp/ |
| H A D | rtp_header.rs | 5 use bytesio::bytes_reader::BytesReader; 25 impl Unmarshal<&mut BytesReader, Result<Self, BytesReadError>> for RtpHeader { 26 fn unmarshal(reader: &mut BytesReader) -> Result<Self, BytesReadError> in unmarshal()
|
| H A D | mod.rs | 14 use bytesio::bytes_reader::BytesReader; 31 impl Unmarshal<&mut BytesReader, Result<Self, BytesReadError>> for RtpPacket { 33 fn unmarshal(reader: &mut BytesReader) -> Result<Self, BytesReadError> in unmarshal()
|
| H A D | rtp_h264.rs | 18 use bytesio::bytes_reader::BytesReader; 56 let mut nalu_reader = BytesReader::new(nalu); in pack_fu_a() 163 fn unpack(&mut self, reader: &mut BytesReader) -> Result<(), UnPackerError> { in unpack() 269 let mut payload_reader = BytesReader::new(rtp_payload); in unpack_fu() 349 let mut payload_reader = BytesReader::new(rtp_payload); in unpack_stap() 433 let mut payload_reader = BytesReader::new(rtp_payload); in unpack_mtap()
|
| /xiu/protocol/rtmp/src/handshake/ |
| H A D | handshake_client.rs | 8 bytesio::{bytes_reader::BytesReader, bytes_writer::AsyncBytesWriter, bytesio::TNetIO}, 18 reader: BytesReader, 27 reader: BytesReader::new(BytesMut::new()), in new()
|
| H A D | digest.rs | 8 bytesio::bytes_reader::BytesReader, 14 reader: BytesReader, 21 reader: BytesReader::new(data), in new() 102 let mut new_reader = BytesReader::new(self.reader.get_remaining_bytes()); in cook_raw_message()
|
| H A D | handshake_server.rs | 9 bytes_reader::BytesReader, bytes_writer::AsyncBytesWriter, bytes_writer::BytesWriter, 17 pub reader: BytesReader, 26 pub reader: BytesReader, 37 reader: BytesReader::new(BytesMut::new()), in new() 89 reader: BytesReader::new(BytesMut::new()), in new() 150 let mut reader = BytesReader::new(c1_bytes); in read_c1() 194 self.c1_timestamp = BytesReader::new(c1_bytes.clone()).read_u32::<BigEndian>()?; in read_c1()
|
| /xiu/protocol/rtmp/src/amf0/ |
| H A D | amf0_reader.rs | 5 bytesio::bytes_reader::BytesReader, 10 reader: BytesReader, 14 pub fn new(reader: BytesReader) -> Self { in new() 182 use bytesio::bytes_reader::BytesReader; 200 let mut bytes_reader = BytesReader::new(BytesMut::new()); in test_amf_reader() 274 let mut bytes_reader = BytesReader::new(BytesMut::new()); in test_number() 327 let mut bytes_reader = BytesReader::new(BytesMut::new()); in test_player_connect_reader()
|
| /xiu/protocol/rtmp/src/cache/ |
| H A D | metadata.rs | 5 bytesio::bytes_reader::BytesReader, 44 let reader = BytesReader::new(body); in is_metadata()
|
| /xiu/library/codec/h264/src/ |
| H A D | sps.rs | 3 bytesio::bytes_reader::BytesReader, std::vec::Vec, 59 pub bytes_reader: BytesReader, 65 pub fn new(reader: BytesReader) -> SpsParser { in new() 67 bytes_reader: BytesReader::new(BytesMut::new()), in new()
|