diff options
| author | Bartek Iwańczuk <biwanczuk@gmail.com> | 2024-07-02 23:37:54 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-07-03 00:37:54 +0200 |
| commit | 7d919f6fd980ed54785e86892a518f0bdf68f475 (patch) | |
| tree | dda1342e996b4d8d19ff0aa17892590822d2b56f /cli/ops | |
| parent | c13b6d1413859d03b41b97d4c671fccfd388b2cc (diff) | |
refactor(jupyter): move ZeroMQ server to a separate thread (#24373)
Moves the ZeroMQ messaging server to a separate thread.
This will allow to run blocking JS code and maintain communication
with the notebook frontend.
Towards https://github.com/denoland/deno/pull/23592
Towards https://github.com/denoland/deno/pull/24250
Closes https://github.com/denoland/deno/issues/23617
Diffstat (limited to 'cli/ops')
| -rw-r--r-- | cli/ops/jupyter.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cli/ops/jupyter.rs b/cli/ops/jupyter.rs index edc5f64ec..5a16caf54 100644 --- a/cli/ops/jupyter.rs +++ b/cli/ops/jupyter.rs @@ -45,11 +45,11 @@ pub async fn op_jupyter_broadcast( ( s.borrow::<Arc<Mutex<KernelIoPubConnection>>>().clone(), - s.borrow::<Rc<RefCell<Option<JupyterMessage>>>>().clone(), + s.borrow::<Arc<Mutex<Option<JupyterMessage>>>>().clone(), ) }; - let maybe_last_request = last_execution_request.borrow().clone(); + let maybe_last_request = last_execution_request.lock().await.clone(); if let Some(last_request) = maybe_last_request { let content = JupyterMessageContent::from_type_and_content( &message_type, |