Function init_worker_handles

components/scheduler/src/vmworkerpool.rs:369–396

(
    pending: PendingWorkerHandle,
    #[cfg(target_family = "windows")] stream: tokio::net::TcpStream,
    #[cfg(target_family = "unix")] stream: tokio::net::UnixStream,
)

}

fn init_worker_handles(
    pending: PendingWorkerHandle,
    #[cfg(target_family = "windows")] stream: tokio::net::TcpStream,
    #[cfg(target_family = "unix")] stream: tokio::net::UnixStream,
) -> WorkerHandle {
    let (scheduler_msg_tx, scheduler_msg_rx) = mpsc::unbounded_channel();
    let (worker_msg_tx, worker_msg_rx) = mpsc::unbounded_channel();

    let (mut reader, mut writer) = stream.into_split();

    tokio::spawn(async move { message_reader(&mut reader, worker_msg_tx).await });

    tokio::spawn(async move { message_writer(&mut writer, scheduler_msg_rx).await });

    WorkerHandle {
        child: pending.child,
        tx: scheduler_msg_tx,
        rx: worker_msg_rx,

        last_active_guild: None,
        returned_at: Instant::now(),
        claimed_at: Instant::now(),
        worker_id: pending.worker_id,
        priority_index: pending.priority_index,

        session_state: None,
    }
}

#[derive(Clone)]
pub struct WorkerLaunchConfig {