Method encode_v1_batch

crates/client-api/src/routes/subscribe.rs:1492–1516

Encode a batch for the original v1 websocket protocols. v1 text/binary messages are encoded one logical message at a time. This path also handles reducer errors, which still use the v1 message schema.

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

    /// v1 text/binary messages are encoded one logical message at a time. This
    /// path also handles reducer errors, which still use the v1 message schema.
    async fn encode_v1_batch(
        &mut self,
        message_batch: &mut Vec<OutboundWsMessage>,
    ) -> Result<(), mpsc::error::SendError<Frame>> {
        for message in message_batch.drain(..) {
            match message {
                OutboundWsMessage::Error(message) => {
                    self.encode_and_forward_v1_message(None, message).await?;
                }
                OutboundWsMessage::Message(message) => {
                    let num_rows = message.num_rows();
                    match message {
                        OutboundMessage::V2(_) => {
                            log::error!("dropping v2 message on v1 connection");
                            continue;
                        }
                        OutboundMessage::V1(message) => {
                            self.encode_and_forward_v1_message(num_rows, message).await?;
                        }
                    }
                }
            }
        }
        Ok(())
    }

    /// Encode a batch for protocol v2.
    ///