toxblh/podcasts
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Pipeline: Minor formatting improvment

Browse Source
This commit is contained in:
Jordan Petridis 2018-09-03 20:30:41 +03:00
parent 3019fcf630
commit 59ad90b989
No known key found for this signature in database
GPG Key ID: E8523968931763BE
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
podcasts-data/src/pipeline.rs
View File

@ -35,9 +35,8 @@ where
sources sources
.and_then(move |s| s.into_feed(client.clone())) .and_then(move |s| s.into_feed(client.clone()))
.and_then(move |feed| { .and_then(move |feed| {
pool.spawn(lazy(|| { let fut = lazy(|| feed.index().map_err(|err| error!("Error: {}", err)));
feed.index().map_err(|err| error!("Error: {}", err)) pool.spawn(fut).map_err(From::from)
})).map_err(From::from)
}) })
// the stream will stop at the first error so // the stream will stop at the first error so
// we ensure that everything will succeded regardless. // we ensure that everything will succeded regardless.