(
subsys: &SubsystemHandle,
state: RuntimeState,
cargo_options: CargoOptions,
watcher_config: WatcherConfig,
)
| 23 | } |
| 24 | |
| 25 | pub(crate) fn init_scheduler( |
| 26 | subsys: &SubsystemHandle, |
| 27 | state: RuntimeState, |
| 28 | cargo_options: CargoOptions, |
| 29 | watcher_config: WatcherConfig, |
| 30 | ) -> Sender<Action> { |
| 31 | let (req_tx, req_rx) = mpsc::channel::<Action>(100); |
| 32 | |
| 33 | subsys.start(SubsystemBuilder::new("lambda scheduler", move |s| { |
| 34 | start_scheduler(s, state, cargo_options, watcher_config, req_rx) |
| 35 | })); |
| 36 | |
| 37 | req_tx |
| 38 | } |
| 39 | |
| 40 | async fn start_scheduler( |
| 41 | subsys: SubsystemHandle, |
no test coverage detected