Lines Matching refs:reader
17 pub reader: BytesReader, field
26 pub reader: BytesReader, field
37 reader: BytesReader::new(BytesMut::new()), in new()
46 self.reader.extend_from_slice(data); in extend_data()
89 reader: BytesReader::new(BytesMut::new()), in new()
99 self.reader.extend_from_slice(data); in extend_data()
142 self.reader.read_u8()?; in read_c0()
147 let c1_bytes = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c1()
150 let mut reader = BytesReader::new(c1_bytes); in read_c1() localVariable
151 self.c1_timestamp = reader.read_u32::<BigEndian>()?; in read_c1()
157 self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c2()
186 self.reader.read_u8()?; in read_c0()
191 let c1_bytes = self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c1()
209 self.reader.read_bytes(define::RTMP_HANDSHAKE_SIZE)?; in read_c2()
307 true => self.complex_handshaker.reader.get_remaining_bytes(), in get_remaining_bytes()
308 false => self.simple_handshaker.reader.get_remaining_bytes(), in get_remaining_bytes()