Function resend_stdio

crates/hyperqueue/src/worker/start/program.rs:215–234

(
    task_id: TaskId,
    channel: ChannelId,
    stdio: Option<impl tokio::io::AsyncRead + Unpin>,
    stream: StreamSender,
)

}

async fn resend_stdio(
    task_id: TaskId,
    channel: ChannelId,
    stdio: Option<impl tokio::io::AsyncRead + Unpin>,
    stream: StreamSender,
) -> tako::Result<()> {
    if let Some(mut stdio) = stdio {
        log::debug!("Resending stream {task_id}/{channel}");
        loop {
            let mut buffer = vec![0; STDIO_BUFFER_SIZE];
            let size = stdio.read(&mut buffer[..]).await?;
            buffer.truncate(size);
            stream.send_data(channel, buffer).await?;
            if size == 0 {
                break;
            };
        }
    }
    Ok(())
}

fn create_directory_if_needed(file: &StdioDef) -> std::io::Result<()> {
    if let StdioDef::File { path, .. } = file