Skip to content

Commit

Permalink
Fix: Don't .forget() RAF closure (#4551)
Browse files Browse the repository at this point in the history
The closure is now stored in `WebRunner` and dropped in the next
`request_animation_frame` instead of being "leaked" via `forget`

---------

Co-authored-by: Emil Ernerfeldt <[email protected]>
  • Loading branch information
jprochazk and emilk authored May 27, 2024
1 parent 759c8fd commit d131b2b
Showing 1 changed file with 35 additions and 11 deletions.
46 changes: 35 additions & 11 deletions crates/eframe/src/web/web_runner.rs
Original file line number Diff line number Diff line change
@@ -1,7 +1,4 @@
use std::{
cell::{Cell, RefCell},
rc::Rc,
};
use std::{cell::RefCell, rc::Rc};

use wasm_bindgen::prelude::*;

Expand Down Expand Up @@ -29,7 +26,7 @@ pub struct WebRunner {
events_to_unsubscribe: Rc<RefCell<Vec<EventToUnsubscribe>>>,

/// Current animation frame in flight.
request_animation_frame_id: Cell<Option<i32>>,
frame: Rc<RefCell<Option<AnimationFrameRequest>>>,

resize_observer: Rc<RefCell<Option<ResizeObserverContext>>>,
}
Expand All @@ -49,7 +46,7 @@ impl WebRunner {
panic_handler,
runner: Rc::new(RefCell::new(None)),
events_to_unsubscribe: Rc::new(RefCell::new(Default::default())),
request_animation_frame_id: Cell::new(None),
frame: Default::default(),
resize_observer: Default::default(),
}
}
Expand Down Expand Up @@ -125,9 +122,9 @@ impl WebRunner {
pub fn destroy(&self) {
self.unsubscribe_from_all_events();

if let Some(id) = self.request_animation_frame_id.get() {
if let Some(frame) = self.frame.take() {
let window = web_sys::window().unwrap();
window.cancel_animation_frame(id).ok();
window.cancel_animation_frame(frame.id).ok();
}

if let Some(runner) = self.runner.replace(None) {
Expand Down Expand Up @@ -202,16 +199,33 @@ impl WebRunner {
Ok(())
}

/// Request an animation frame from the browser in which we can perform a paint.
///
/// It is safe to call `request_animation_frame` multiple times in quick succession,
/// this function guarantees that only one animation frame is scheduled at a time.
pub(crate) fn request_animation_frame(&self) -> Result<(), wasm_bindgen::JsValue> {
if self.frame.borrow().is_some() {
// there is already an animation frame in flight
return Ok(());
}

let window = web_sys::window().unwrap();
let closure = Closure::once({
let runner_ref = self.clone();
move || events::paint_and_schedule(&runner_ref)
move || {
// We can paint now, so clear the animation frame.
// This drops the `closure` and allows another
// animation frame to be scheduled
let _ = runner_ref.frame.take();
events::paint_and_schedule(&runner_ref)
}
});

let id = window.request_animation_frame(closure.as_ref().unchecked_ref())?;
self.request_animation_frame_id.set(Some(id));
closure.forget(); // We must forget it, or else the callback is canceled on drop
self.frame.borrow_mut().replace(AnimationFrameRequest {
id,
_closure: closure,
});

Ok(())
}
Expand All @@ -232,6 +246,16 @@ impl WebRunner {

// ----------------------------------------------------------------------------

// https://rustwasm.github.io/wasm-bindgen/api/wasm_bindgen/closure/struct.Closure.html#using-fnonce-and-closureonce-with-requestanimationframe
struct AnimationFrameRequest {
/// Represents the ID of a frame in flight.
id: i32,

/// The callback given to `request_animation_frame`, stored here both to prevent it
/// from being canceled, and from having to `.forget()` it.
_closure: Closure<dyn FnMut() -> Result<(), JsValue>>,
}

struct ResizeObserverContext {
resize_observer: web_sys::ResizeObserver,
closure: Closure<dyn FnMut(js_sys::Array)>,
Expand Down

0 comments on commit d131b2b

Please sign in to comment.