7     writer: AsyncBytesWriter,  field
12     pub fn new(writer: AsyncBytesWriter) -> Self {  in new()
13         Self { writer }  in new()
25         self.writer.write_u8(0x02)?; //fmt 0 and csid 2 //0x0 << 6 | 0x02  in write_control_message_header()
26         self.writer.write_u24::<BigEndian>(0)?; //timestamp 3 bytes and value 0  in write_control_message_header()
27         self.writer.write_u24::<BigEndian>(len)?; //msg length  in write_control_message_header()
28         self.writer.write_u8(msg_type_id)?; //msg type id  in write_control_message_header()
29         self.writer.write_u32::<BigEndian>(0)?; //msg stream ID 0  in write_control_message_header()
38         self.writer  in write_set_chunk_size()
41         self.writer.flush().await?;  in write_set_chunk_size()
50         self.writer.write_u32::<BigEndian>(chunk_stream_id)?;  in write_abort_message()
52         self.writer.flush().await?;  in write_abort_message()
61         self.writer.write_u32::<BigEndian>(sequence_number)?;  in write_acknowledgement()
63         self.writer.flush().await?;  in write_acknowledgement()
72         self.writer.write_u32::<BigEndian>(window_size)?;  in write_window_acknowledgement_size()
74         self.writer.flush().await?;  in write_window_acknowledgement_size()
84         self.writer.write_u32::<BigEndian>(window_size)?;  in write_set_peer_bandwidth()
85         self.writer.write_u8(limit_type)?;  in write_set_peer_bandwidth()
87         self.writer.flush().await?;  in write_set_peer_bandwidth()