From e633fa41acf063ef8ac65f3083170644152be66b Mon Sep 17 00:00:00 2001 From: Jordan Petridis Date: Mon, 3 Sep 2018 20:30:41 +0300 Subject: [PATCH] Pipeline: Minor formatting improvment --- podcasts-data/src/pipeline.rs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/podcasts-data/src/pipeline.rs b/podcasts-data/src/pipeline.rs index 89200fd..0716c01 100644 --- a/podcasts-data/src/pipeline.rs +++ b/podcasts-data/src/pipeline.rs @@ -35,9 +35,8 @@ where sources .and_then(move |s| s.into_feed(client.clone())) .and_then(move |feed| { - pool.spawn(lazy(|| { - feed.index().map_err(|err| error!("Error: {}", err)) - })).map_err(From::from) + let fut = lazy(|| feed.index().map_err(|err| error!("Error: {}", err))); + pool.spawn(fut).map_err(From::from) }) // the stream will stop at the first error so // we ensure that everything will succeded regardless.