Method spawn_collector

core/src/agent_api/runtime_events.rs:83–92

(
        self,
        mut runtime_rx: mpsc::Receiver<AgentEvent>,
    )

    }

    pub(super) fn spawn_collector(
        self,
        mut runtime_rx: mpsc::Receiver<AgentEvent>,
    ) -> JoinHandle<()> {
        tokio::spawn(async move {
            while let Some(event) = runtime_rx.recv().await {
                self.observe(&event).await;
            }
        })
    }

    pub(super) fn spawn_forwarder(
        self,