cargo fmt

podcasts-data/src/feed.rs

@@ -87,21 +87,22 @@ fn filter_episodes<'a, S>(
 where
     S: Stream<Item = IndexState<NewEpisode>, Error = DataError> + Send + 'a,
 {
-    stream.filter_map(|state| match state {
+    stream
-        IndexState::NotChanged => None,
+        .filter_map(|state| match state {
-        // Update individual rows, and filter them
+            IndexState::NotChanged => None,
-        IndexState::Update((ref ep, rowid)) => {
+            // Update individual rows, and filter them
-            ep.update(rowid)
+            IndexState::Update((ref ep, rowid)) => {
-                .map_err(|err| error!("{}", err))
+                ep.update(rowid)
-                .map_err(|_| error!("Failed to index episode: {:?}.", ep.title()))
+                    .map_err(|err| error!("{}", err))
-                .ok();
+                    .map_err(|_| error!("Failed to index episode: {:?}.", ep.title()))
+                    .ok();
 
-            None
+                None
-        },
+            }
-        IndexState::Index(s) => Some(s),
+            IndexState::Index(s) => Some(s),
-    })
+        })
-    // only Index is left, collect them for batch index
+        // only Index is left, collect them for batch index
-    .collect()
+        .collect()
 }
 
 fn batch_insert_episodes(episodes: &[NewEpisode]) {

podcasts-data/src/models/new_episode.rs

@@ -217,7 +217,8 @@ impl NewEpisodeMinimal {
         let enc = item.enclosure();
 
         // Get the url
-        let uri = enc.map(|s| url_cleaner(s.url().trim()))
+        let uri = enc
+            .map(|s| url_cleaner(s.url().trim()))
             // Fallback to Rss.Item.link if enclosure is None.
             .or_else(|| item.link().map(|s| url_cleaner(s.trim())));