diff options
| author | Aapo Alasuutari <aapo.alasuutari@gmail.com> | 2022-06-28 12:23:36 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-06-28 14:53:36 +0530 |
| commit | 00f4521b205bf25c79f0fa7c9a6840941342bda4 (patch) | |
| tree | b988db360143384ae216022846b518ceb262c80a /core/examples/schedule_task.rs | |
| parent | e1c90963fbbf6571ae1b66971b83159681928ec3 (diff) | |
feat(ext/ffi): Thread safe callbacks (#14942)
Diffstat (limited to 'core/examples/schedule_task.rs')
| -rw-r--r-- | core/examples/schedule_task.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/core/examples/schedule_task.rs b/core/examples/schedule_task.rs index 7812dcb49..bd4bcb028 100644 --- a/core/examples/schedule_task.rs +++ b/core/examples/schedule_task.rs @@ -20,7 +20,8 @@ type Task = Box<dyn FnOnce()>; fn main() { let my_ext = Extension::builder() .ops(vec![op_schedule_task::decl()]) - .event_loop_middleware(|state, cx| { + .event_loop_middleware(|state_rc, cx| { + let mut state = state_rc.borrow_mut(); let recv = state.borrow_mut::<mpsc::UnboundedReceiver<Task>>(); let mut ref_loop = false; while let Poll::Ready(Some(call)) = recv.poll_next_unpin(cx) { |