use futures::prelude::*;

        let subscription_limit = config.download_subscription_limit.unwrap_or(-1);

        let to_download = match config.download_subscription_limit {
            Some(subscription_limit) => {
                let download_futures = episodes
                    .iter()
                    .rev()
                    .take(subscription_limit as usize)
                    .map(|ep| Download::new(&state, &podcast, &ep));

        let mut to_download = vec![];
        if 0 < subscription_limit {
            for ep in episodes.iter().rev().take(subscription_limit as usize) {
                if let Some(episode) = Download::new(&state, &podcast, &ep).await? {
                    to_download.push(episode)
                }

                stream::iter(download_futures)
                    .filter_map(|download| async move { download.await.ok() })
                    .filter_map(|d| async move { d })
                    .collect::<Vec<Download>>()
                    .await

        } else {
            for ep in episodes.iter() {
                if let Some(episode) = Download::new(&state, &podcast, &ep).await? {
                    to_download.push(episode)
                }

            None => {
                let download_futures = episodes
                    .iter()
                    .map(|ep| Download::new(&state, &podcast, &ep));
                stream::iter(download_futures)
                    .filter_map(|download| async move { download.await.ok() })
                    .filter_map(|d| async move { d })
                    .collect::<Vec<Download>>()
                    .await

        }

        };