Method send_plan

nodedb/src/data/executor/dispatch/array/tests_dispatch.rs:106–117

(&mut self, plan: PhysicalPlan)

    }

    fn send_plan(&mut self, plan: PhysicalPlan) -> crate::bridge::envelope::Response {
        let id = self.next_id;
        self.next_id += 1;
        self.req_tx
            .try_push(BridgeRequest {
                inner: make_request(plan, id),
            })
            .unwrap();
        self.core.tick();
        let resp = self.resp_rx.try_pop().unwrap();
        resp.inner
    }

    fn open(&mut self, aid: &ArrayId, schema: &ArraySchema, schema_hash: u64) {
        let bytes = zerompk::to_msgpack_vec(schema).unwrap();