(
core: &mut CoreLoop,
tx: &mut Producer<BridgeRequest>,
rx: &mut Consumer<BridgeResponse>,
plan: PhysicalPlan,
)
| 80 | } |
| 81 | |
| 82 | pub fn send_raw( |
| 83 | core: &mut CoreLoop, |
| 84 | tx: &mut Producer<BridgeRequest>, |
| 85 | rx: &mut Consumer<BridgeResponse>, |
| 86 | plan: PhysicalPlan, |
| 87 | ) -> nodedb::bridge::envelope::Response { |
| 88 | tx.try_push(BridgeRequest { |
| 89 | inner: make_request(plan), |
| 90 | }) |
| 91 | .unwrap(); |
| 92 | core.tick(); |
| 93 | rx.try_pop().unwrap().inner |
| 94 | } |
| 95 | |
| 96 | pub fn payload_json(payload: &[u8]) -> String { |
| 97 | nodedb::data::executor::response_codec::decode_payload_to_json(payload) |
no test coverage detected