WIP

prisma · Dec 4, 2023 · 3fa412b · 3fa412b
1 parent 248210d
commit 3fa412b
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...y-engine/connector-test-kit-rs/query-tests-setup/src/connector_tag/js/external_process.rs b/...y-engine/connector-test-kit-rs/query-tests-setup/src/connector_tag/js/external_process.rs
@@ -175,6 +175,7 @@ fn start_rpc_thread(mut receiver: mpsc::Receiver<ReqImpl>) -> Result<()> {
             let mut stdin = process.stdin.unwrap();
             let mut pending_requests: HashMap<jsonrpc_core::Id, oneshot::Sender<Result<serde_json::value::Value>>> =
                 HashMap::new();
+            let mut last_pending_request_id: Option<jsonrpc_core::Id> = None;
 
             loop {
                 tokio::select! {
@@ -226,6 +227,8 @@ fn start_rpc_thread(mut receiver: mpsc::Receiver<ReqImpl>) -> Result<()> {
                             }
                             Some((request, response_sender)) => {
                                 pending_requests.insert(request.id.clone(), response_sender);
+                                last_pending_request_id = Some(request.id.clone());
+
                                 let mut req = serde_json::to_vec(&request).unwrap();
                                 req.push(b'\n');
                                 stdin.write_all(&req).await.unwrap();