Method register

nodedb/src/control/request_tracker.rs:53–57

Register a pending request. Returns a bounded receiver the session awaits. For non-streaming requests, exactly one response arrives. For streaming requests, multiple partial responses arrive before the final one. Channel capacity applies backpressure when the session is slow.

(&self, id: RequestId)

    /// For streaming requests, multiple partial responses arrive before the final one.
    /// Channel capacity applies backpressure when the session is slow.
    pub fn register(&self, id: RequestId) -> mpsc::Receiver<Response> {
        let (tx, rx) = mpsc::channel(REQUEST_CHANNEL_CAPACITY);
        self.lock_pending().insert(id, tx);
        rx
    }

    /// Forward a response from the Data Plane to the waiting session.
    ///