Feed: Remove another unnecessary wrapper
This commit is contained in:
parent
1028d1334b
commit
9c693c4c42
@ -40,7 +40,8 @@ impl Feed {
|
|||||||
|
|
||||||
// Parse the episodes
|
// Parse the episodes
|
||||||
let episodes = stream.filter_map(move |item| {
|
let episodes = stream.filter_map(move |item| {
|
||||||
glue(&item, pd.id())
|
NewEpisodeMinimal::new(&item, pd.id())
|
||||||
|
.and_then(move |ep| determine_ep_state(ep, &item))
|
||||||
.map_err(|err| error!("Failed to parse an episode: {}", err))
|
.map_err(|err| error!("Failed to parse an episode: {}", err))
|
||||||
.ok()
|
.ok()
|
||||||
});
|
});
|
||||||
@ -52,10 +53,6 @@ impl Feed {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn glue(item: &rss::Item, id: i32) -> Result<IndexState<NewEpisode>, DataError> {
|
|
||||||
NewEpisodeMinimal::new(item, id).and_then(move |ep| determine_ep_state(ep, item))
|
|
||||||
}
|
|
||||||
|
|
||||||
fn determine_ep_state(
|
fn determine_ep_state(
|
||||||
ep: NewEpisodeMinimal,
|
ep: NewEpisodeMinimal,
|
||||||
item: &rss::Item,
|
item: &rss::Item,
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user