Enter Runtime when calling Program::subscription
This commit is contained in:
parent
b7ba613dbc
commit
c66355f289
1 changed files with 2 additions and 2 deletions
|
|
@ -219,7 +219,7 @@ where
|
||||||
}
|
}
|
||||||
|
|
||||||
runtime.track(subscription::into_recipes(
|
runtime.track(subscription::into_recipes(
|
||||||
program.subscription().map(Action::Output),
|
runtime.enter(|| program.subscription().map(Action::Output)),
|
||||||
));
|
));
|
||||||
|
|
||||||
let (boot_sender, boot_receiver) = oneshot::channel();
|
let (boot_sender, boot_receiver) = oneshot::channel();
|
||||||
|
|
@ -1169,7 +1169,7 @@ fn update<P: Program, E: Executor>(
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
let subscription = program.subscription();
|
let subscription = runtime.enter(|| program.subscription());
|
||||||
runtime.track(subscription::into_recipes(subscription.map(Action::Output)));
|
runtime.track(subscription::into_recipes(subscription.map(Action::Output)));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue