pub async fn encoder( rx: impl Stream<Item = PacketBuf>, protocol: ProtocolVersion, supports_binary: bool, max_payload: u64, ) -> Payload
Encodes a payload into a byte stream.