Method encode_batch

crates/client-api/src/routes/subscribe.rs:1477–1486

Encode a drained batch according to the websocket version negotiated by the client.

(
        &mut self,
        message_batch: &mut Vec<OutboundWsMessage>,
    )

    /// Encode a drained batch according to the websocket version negotiated by
    /// the client.
    async fn encode_batch(
        &mut self,
        message_batch: &mut Vec<OutboundWsMessage>,
    ) -> Result<(), mpsc::error::SendError<Frame>> {
        match self.config.version {
            WsVersion::V1 => self.encode_v1_batch(message_batch).await,
            WsVersion::V2 => self.encode_v2_batch(message_batch).await,
            WsVersion::V3 => self.encode_v3_batch(message_batch).await,
        }
    }

    /// Encode a batch for the original v1 websocket protocols.
    ///