Method encode_and_drain

crates/batcher/encoder/src/encoder.rs:149–162

Step the encoder until idle, force-close the current channel, and return all frames from every available submission. Convenience wrapper for tests and one-shot batch pipelines that have already added all blocks via [`BatchPipeline::add_block`] and want all output frames in a single call. # Errors Returns the first [`StepError`] encountered during encoding. On error the encoder state is left as-

(&mut self)

    /// encoder state is left as-is; previously ready submissions remain available
    /// via [`BatchPipeline::next_submission`].
    pub fn encode_and_drain(&mut self) -> Result<Vec<Arc<Frame>>, StepError> {
        loop {
            match self.step()? {
                StepResult::Idle => break,
                StepResult::BlockEncoded | StepResult::SpanFlushed | StepResult::ChannelClosed => {}
            }
        }
        self.close_current_channel("force")?;
        let mut frames = Vec::new();
        while let Some(sub) = self.next_submission() {
            frames.extend(sub.frames);
        }
        Ok(frames)
    }

    /// Build a span batch from the current accumulator.
    fn build_span_batch(&self) -> Result<SpanBatch, StepError> {