Method add_to_batch

core/src/ahp/executor.rs:445–457

Add an event to the batch buffer. Returns true if the batch should be flushed (size threshold reached).

(&self, event: a3s_ahp::AhpEvent)

    ///
    /// Returns true if the batch should be flushed (size threshold reached).
    pub async fn add_to_batch(&self, event: a3s_ahp::AhpEvent) -> bool {
        let should_flush = {
            let mut buffer = write_or_recover(&self.batch_buffer);
            buffer.push(event);
            buffer.len() >= self.batch_size
        };

        if should_flush {
            self.flush_batch().await;
        }

        should_flush
    }

    /// Flush the batch buffer and send all events.
    pub async fn flush_batch(&self) {