18     pub writer: AsyncBytesWriter,  field
27     pub writer: AsyncBytesWriter,  field
38             writer: AsyncBytesWriter::new(io),  in new()
64                     self.writer.flush().await?;  in handshake()
90             writer: AsyncBytesWriter::new(io),  in new()
117                     self.writer.flush().await?;  in handshake()
162         self.writer.write_u8(define::RTMP_VERSION as u8)?;  in write_s0()
167         self.writer.write_u32::<BigEndian>(utils::current_time())?;  in write_s1()
170         self.writer.write_u32::<BigEndian>(timestamp)?;  in write_s1()
172         self.writer  in write_s1()
179         self.writer.write(&data[..])?;  in write_s2()
214         self.writer.write_u8(define::RTMP_VERSION as u8)?;  in write_s0()
220         let mut writer = BytesWriter::new();  in write_s1()  localVariable
222         writer.write_u32::<BigEndian>(utils::current_time())?;  in write_s1()
223         writer.write(&define::RTMP_SERVER_VERSION)?;  in write_s1()
224         writer.write_random_bytes(define::RTMP_HANDSHAKE_SIZE as u32 - 8)?;  in write_s1()
230         let mut digest_processor = DigestProcessor::new(writer.extract_current_bytes(), key);  in write_s1()
234         self.writer.write(&content[..])?;  in write_s1()
240         let mut writer = BytesWriter::new();  in write_s2()  localVariable
242         writer.write_u32::<BigEndian>(utils::current_time())?;  in write_s2()
243         writer.write_u32::<BigEndian>(self.c1_timestamp)?;  in write_s2()
244         writer.write_random_bytes(define::RTMP_HANDSHAKE_SIZE as u32 - 8)?;  in write_s2()
255         data.extend_from_slice(&writer.get_current_bytes()[..1504]);  in write_s2()
263         self.writer.write(&content[..])?;  in write_s2()