pb.set_message(&format!("Downloading {}", &episode.title));

    let mut title = episode.title.to_owned();
    title.truncate(40);
    pb.set_message(&title);

        let mut title = episode.title.to_owned();
        title.truncate(40);

        pb.set_message(&format!("Downloading {}", &episode.title));

        pb.set_message(&title);

    if let Some(index) = state.subscriptions.iter().position(|sub| re_pod.is_match(sub.title())) {

    if let Some(index) = state
        .subscriptions
        .iter()
        .position(|sub| re_pod.is_match(sub.title()))
    {

use futures::future;

use std::thread;

    smol::run(async {

    // Same number of threads as there are CPU cores.
    let num_threads = num_cpus::get().max(1);
    // Run the thread-local and work-stealing executor on a thread pool.
    for _ in 0..num_threads {
        // A pending future is one that simply yields forever.
        thread::spawn(|| smol::run(future::pending::<()>()));
    }
    smol::block_on(async {

        serde_json::to_writer(BufWriter::new(file), self)?;

        serde_json::to_writer_pretty(BufWriter::new(file), self)?;