Lines Matching refs:writer
25 writer: AsyncBytesWriter, field
34 writer: AsyncBytesWriter::new(io), in new()
88 self.writer.write_u8(fmt << 6 | 1)?; in write_basic_header()
89 self.writer.write_u16::<BigEndian>((csid - 64) as u16)?; in write_basic_header()
91 self.writer.write_u8(fmt << 6)?; in write_basic_header()
92 self.writer.write_u8((csid - 64) as u8)?; in write_basic_header()
94 self.writer.write_u8(fmt << 6 | csid as u8)?; in write_basic_header()
138 self.writer in write_message_header()
140 self.writer in write_message_header()
142 self.writer.write_u8(message_header.msg_type_id)?; in write_message_header()
143 self.writer in write_message_header()
147 self.writer in write_message_header()
149 self.writer in write_message_header()
151 self.writer.write_u8(message_header.msg_type_id)?; in write_message_header()
154 self.writer in write_message_header()
164 self.writer.write_u32::<BigEndian>(timestamp)?; in write_extened_timestamp()
199 self.writer.write(&payload_bytes[0..])?; in write_chunk()
211 self.writer.flush().await?; in write_chunk()