Merge pull request #772 from Demonthos/fix-future-on-dropped-scope
This commit is contained in:
2 files changed
+10
-1
No files matched your search
@@ -116,6 +116,11 @@ impl VirtualDom {
|
|||||||
for hook in scope.hook_list.get_mut().drain(..) {
|
for hook in scope.hook_list.get_mut().drain(..) {
|
||||||
drop(unsafe { BumpBox::from_raw(hook) });
|
drop(unsafe { BumpBox::from_raw(hook) });
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Drop all the futures once the hooks are dropped
|
||||||
|
for task_id in scope.spawned_tasks.borrow_mut().drain() {
|
||||||
|
scope.tasks.remove(task_id);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn drop_scope_inner(&mut self, node: &VNode) {
|
fn drop_scope_inner(&mut self, node: &VNode) {
|
||||||
|
|||||||
@@ -319,7 +319,9 @@ impl<'src> ScopeState {
|
|||||||
|
|
||||||
/// Pushes the future onto the poll queue to be polled after the component renders.
|
/// Pushes the future onto the poll queue to be polled after the component renders.
|
||||||
pub fn push_future(&self, fut: impl Future<Output = ()> + 'static) -> TaskId {
|
pub fn push_future(&self, fut: impl Future<Output = ()> + 'static) -> TaskId {
|
||||||
self.tasks.spawn(self.id, fut)
|
let id = self.tasks.spawn(self.id, fut);
|
||||||
|
self.spawned_tasks.borrow_mut().insert(id);
|
||||||
|
id
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Spawns the future but does not return the [`TaskId`]
|
/// Spawns the future but does not return the [`TaskId`]
|
||||||
@@ -340,6 +342,8 @@ impl<'src> ScopeState {
|
|||||||
.unbounded_send(SchedulerMsg::TaskNotified(id))
|
.unbounded_send(SchedulerMsg::TaskNotified(id))
|
||||||
.expect("Scheduler should exist");
|
.expect("Scheduler should exist");
|
||||||
|
|
||||||
|
self.spawned_tasks.borrow_mut().insert(id);
|
||||||
|
|
||||||
id
|
id
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in new issue
Block a user