Method batch

indexer/src/validator.rs:41–65

(&mut self, messages: impl Iterator<Item = SharedMessage> + Send)

#[async_trait]
impl Processor for Validator {
    async fn batch(&mut self, messages: impl Iterator<Item = SharedMessage> + Send) -> Result<()> {
        for message in messages {
            match message.header().stream_key().name() {
                INFO_STREAM => self.data.debugger_infos.push({
                    let mut debugger_info = deser_info(&message);
                    debugger_info.redacted();
                    debugger_info
                }),
                FILE_STREAM => self.data.files.push({
                    let mut file: SourceFile = deser(&message);
                    file.redacted();
                    file
                }),
                BREAKPOINT_STREAM => self.data.breakpoints.push(deser(&message)),
                EVENT_STREAM => {
                    let mut event = EventStream::read_from(message.message().into_bytes().into());
                    event.redacted();
                    self.data.events.push(event);
                }
                ALLOCATION_STREAM => {}
                _ => anyhow::bail!("Unexpected stream key {}", message.stream_key()),
            }
        }
        Ok(())
    }

    async fn end(&mut self) -> Result<()> {
        Ok(())