Run everything through latest rustfmt

examples/src/bin/appsink.rs

@@ -115,12 +115,14 @@ fn create_pipeline() -> Result<gst::Pipeline, Error> {
                     .map(|sample| {
                         let f = f64::from(*sample) / f64::from(i16::MAX);
                         f * f
-                    }).sum();
+                    })
+                    .sum();
                 let rms = (sum / (samples.len() as f64)).sqrt();
                 println!("rms: {}", rms);
 
                 gst::FlowReturn::Ok
-            }).build(),
+            })
+            .build(),
     );
 
     Ok(pipeline)

examples/src/bin/appsrc.rs

@@ -105,7 +105,8 @@ fn create_pipeline() -> Result<gst::Pipeline, Error> {
 
                 // appsrc already handles the error here
                 let _ = appsrc.push_buffer(buffer);
-            }).build(),
+            })
+            .build(),
     );
 
     Ok(pipeline)

examples/src/bin/decodebin.rs

@@ -178,7 +178,8 @@ fn example_main() -> Result<(), Error> {
                             .and_then(|v| {
                                 v.downcast_ref::<Arc<Mutex<Option<Error>>>>()
                                     .and_then(|v| v.lock().unwrap().take())
-                            }).map(Result::Err)
+                            })
+                            .map(Result::Err)
                             .expect("error-details message without actual error"),
                         _ => Err(ErrorMessage {
                             src: err
@@ -188,7 +189,8 @@ fn example_main() -> Result<(), Error> {
                             error: err.get_error().description().into(),
                             debug: err.get_debug(),
                             cause: err.get_error(),
-                        }.into()),
+                        }
+                        .into()),
                     }?;
                 }
                 #[cfg(not(feature = "v1_10"))]

examples/src/bin/encodebin.rs

@@ -236,7 +236,8 @@ fn example_main() -> Result<(), Error> {
                             .and_then(|v| {
                                 v.downcast_ref::<Arc<Mutex<Option<Error>>>>()
                                     .and_then(|v| v.lock().unwrap().take())
-                            }).map(Result::Err)
+                            })
+                            .map(Result::Err)
                             .expect("error-details message without actual error"),
                         _ => Err(ErrorMessage {
                             src: err
@@ -246,7 +247,8 @@ fn example_main() -> Result<(), Error> {
                             error: err.get_error().description().into(),
                             debug: err.get_debug(),
                             cause: err.get_error(),
-                        }.into()),
+                        }
+                        .into()),
                     }?;
                 }
                 #[cfg(not(feature = "v1_10"))]

examples/src/bin/futures.rs

@@ -44,7 +44,8 @@ fn example_main() {
             } else {
                 Ok(())
             }
-        }).and_then(|_| Ok(()));
+        })
+        .and_then(|_| Ok(()));
 
     let _ = block_on(messages);
 

examples/src/bin/glib-futures.rs

@@ -47,7 +47,8 @@ fn example_main() {
             } else {
                 Ok(())
             }
-        }).and_then(|_| Ok(()));
+        })
+        .and_then(|_| Ok(()));
 
     let _ = ctx.block_on(messages);
 

examples/src/bin/pad_probes.rs

@@ -16,7 +16,8 @@ fn example_main() {
     let pipeline = gst::parse_launch(&format!(
         "audiotestsrc name=src ! audio/x-raw,format={},channels=1 ! fakesink",
         gst_audio::AUDIO_FORMAT_S16.to_string()
-    )).unwrap();
+    ))
+    .unwrap();
     let pipeline = pipeline.dynamic_cast::<gst::Pipeline>().unwrap();
 
     let src = pipeline.get_by_name("src").unwrap();
@@ -36,7 +37,8 @@ fn example_main() {
                 .map(|sample| {
                     let f = f64::from(*sample) / f64::from(i16::MAX);
                     f * f
-                }).sum();
+                })
+                .sum();
             let rms = (sum / (samples.len() as f64)).sqrt();
             println!("rms: {}", rms);
         }

examples/src/bin/pango-cairo.rs

@@ -146,7 +146,8 @@ fn create_pipeline() -> Result<gst::Pipeline, Error> {
             }
 
             None
-        }).unwrap();
+        })
+        .unwrap();
 
     let drawer_clone = drawer.clone();
     overlay
@@ -159,7 +160,8 @@ fn create_pipeline() -> Result<gst::Pipeline, Error> {
             drawer.info = Some(gst_video::VideoInfo::from_caps(&caps).unwrap());
 
             None
-        }).unwrap();
+        })
+        .unwrap();
 
     Ok(pipeline)
 }

examples/src/bin/playbin.rs

@@ -60,7 +60,8 @@ fn example_main() {
             }
 
             None
-        }).unwrap();
+        })
+        .unwrap();
 
     let bus = playbin.get_bus().unwrap();
 

examples/src/bin/queries.rs

@@ -39,7 +39,8 @@ fn example_main() {
             } else {
                 None
             }
-        }.and_then(|pos| pos.try_into_time().ok())
+        }
+        .and_then(|pos| pos.try_into_time().ok())
         .unwrap();
 
         let dur = {
@@ -49,7 +50,8 @@ fn example_main() {
             } else {
                 None
             }
-        }.and_then(|dur| dur.try_into_time().ok())
+        }
+        .and_then(|dur| dur.try_into_time().ok())
         .unwrap();
 
         println!("{} / {}", pos, dur);

examples/src/bin/rtpfecclient.rs

@@ -172,7 +172,8 @@ fn example_main() -> Result<(), Error> {
                         ("clock-rate", &90000i32),
                         ("is-fec", &true),
                     ],
-                ).to_value(),
+                )
+                .to_value(),
             ),
             96 => Some(
                 gst::Caps::new_simple(
@@ -182,7 +183,8 @@ fn example_main() -> Result<(), Error> {
                         ("clock-rate", &90000i32),
                         ("encoding-name", &"VP8"),
                     ],
-                ).to_value(),
+                )
+                .to_value(),
             ),
             _ => None,
         }
@@ -266,17 +268,20 @@ fn example_main() -> Result<(), Error> {
                     error: err.get_error().description().into(),
                     debug: err.get_debug(),
                     cause: err.get_error(),
-                }.into());
+                }
+                .into());
             }
             MessageView::StateChanged(s) => match msg.get_src() {
-                Some(element) => if element == pipeline && s.get_current() == gst::State::Playing {
+                Some(element) => {
-                    eprintln!("PLAYING");
+                    if element == pipeline && s.get_current() == gst::State::Playing {
-                    gst::debug_bin_to_dot_file(
+                        eprintln!("PLAYING");
-                        &pipeline,
+                        gst::debug_bin_to_dot_file(
-                        gst::DebugGraphDetails::all(),
+                            &pipeline,
-                        "client-playing",
+                            gst::DebugGraphDetails::all(),
-                    );
+                            "client-playing",
-                },
+                        );
+                    }
+                }
                 None => (),
             },
             _ => (),

examples/src/bin/rtpfecserver.rs

@@ -199,17 +199,20 @@ fn example_main() -> Result<(), Error> {
                     error: err.get_error().description().into(),
                     debug: err.get_debug(),
                     cause: err.get_error(),
-                }.into());
+                }
+                .into());
             }
             MessageView::StateChanged(s) => match msg.get_src() {
-                Some(element) => if element == pipeline && s.get_current() == gst::State::Playing {
+                Some(element) => {
-                    eprintln!("PLAYING");
+                    if element == pipeline && s.get_current() == gst::State::Playing {
-                    gst::debug_bin_to_dot_file(
+                        eprintln!("PLAYING");
-                        &pipeline,
+                        gst::debug_bin_to_dot_file(
-                        gst::DebugGraphDetails::all(),
+                            &pipeline,
-                        "server-playing",
+                            gst::DebugGraphDetails::all(),
-                    );
+                            "server-playing",
-                },
+                        );
+                    }
+                }
                 None => (),
             },
             _ => (),

gstreamer-net/src/net_client_clock.rs

@@ -31,7 +31,8 @@ impl NetClientClock {
                     remote_address.to_glib_none().0,
                     remote_port,
                     base_time.to_glib(),
-                )).downcast_unchecked()
+                ))
+                .downcast_unchecked()
             }
         } else {
             // Workaround for bad floating reference handling in 1.12. This issue was fixed for 1.13
@@ -41,7 +42,8 @@ impl NetClientClock {
                     remote_address.to_glib_none().0,
                     remote_port,
                     base_time.to_glib(),
-                )).downcast_unchecked()
+                ))
+                .downcast_unchecked()
             }
         }
     }

gstreamer-net/src/ntp_clock.rs

@@ -31,7 +31,8 @@ impl NtpClock {
                     remote_address.to_glib_none().0,
                     remote_port,
                     base_time.to_glib(),
-                )).downcast_unchecked()
+                ))
+                .downcast_unchecked()
             }
         } else {
             // Workaround for bad floating reference handling in 1.12. This issue was fixed for 1.13
@@ -41,7 +42,8 @@ impl NtpClock {
                     remote_address.to_glib_none().0,
                     remote_port,
                     base_time.to_glib(),
-                )).downcast_unchecked()
+                ))
+                .downcast_unchecked()
             }
         }
     }

gstreamer-net/src/ptp_clock.rs

@@ -31,7 +31,8 @@ impl PtpClock {
                     remote_address.to_glib_none().0,
                     remote_port,
                     base_time.to_glib(),
-                )).downcast_unchecked()
+                ))
+                .downcast_unchecked()
             }
         } else {
             // Workaround for bad floating reference handling in 1.12. This issue was fixed for 1.13
@@ -41,7 +42,8 @@ impl PtpClock {
                     remote_address.to_glib_none().0,
                     remote_port,
                     base_time.to_glib(),
-                )).downcast_unchecked()
+                ))
+                .downcast_unchecked()
             }
         }
     }

gstreamer/src/buffer_serde.rs

@@ -117,7 +117,8 @@ mod tests {
                 "    ),",
                 "    buffer: \"AQIDBA==\",",
                 ")"
-            ).to_owned()),
+            )
+            .to_owned()),
             res
         );
 
@@ -133,7 +134,8 @@ mod tests {
                 "\"flags\":{\"bits\":1048592},",
                 "\"buffer\":[1,2,3,4]",
                 "}"
-            ).to_owned(),
+            )
+            .to_owned(),
             res
         );
 

gstreamer/src/bufferlist_serde.rs

@@ -131,7 +131,8 @@ mod tests {
                 "        buffer: \"BQY=\",",
                 "    ),",
                 "]"
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
     }

gstreamer/src/caps.rs

@@ -579,7 +579,8 @@ mod tests {
                         ("fraction", &Fraction::new(1, 2)),
                         ("array", &Array::new(&[&1, &2])),
                     ],
-                ).as_ref()
+                )
+                .as_ref()
             );
         }
         assert!(

gstreamer/src/caps_serde.rs

@@ -264,7 +264,8 @@ mod tests {
                 "        ]),",
                 "    ]), None),",
                 "])"
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
 
@@ -298,7 +299,8 @@ mod tests {
                 "        \"foo:baz\",",
                 "    ]))),",
                 "])"
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
 
@@ -329,7 +331,8 @@ mod tests {
                 "        ]),",
                 "    ]), Some(Any)),",
                 "])"
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
 
@@ -385,7 +388,8 @@ mod tests {
                     ("fraction", &Fraction::new(1, 2)),
                     ("array", &Array::new(&[&1, &2])),
                 ],
-            ).as_ref()
+            )
+            .as_ref()
         );
 
         let caps_ron = r#"
@@ -417,7 +421,8 @@ mod tests {
                     ("fraction", &Fraction::new(1, 2)),
                     ("array", &Array::new(&[&1, &2])),
                 ],
-            ).as_ref()
+            )
+            .as_ref()
         );
         let f = caps.get_features(0).unwrap();
         assert!(f.is_equal(CapsFeatures::new(&["foo:bar", "foo:baz"]).as_ref()));
@@ -451,7 +456,8 @@ mod tests {
                     ("fraction", &Fraction::new(1, 2)),
                     ("array", &Array::new(&[&1, &2])),
                 ],
-            ).as_ref()
+            )
+            .as_ref()
         );
         let f = caps.get_features(0).unwrap();
         assert!(f.is_any());

gstreamer/src/clock.rs

@@ -43,7 +43,8 @@ unsafe extern "C" fn trampoline_wait_async(
         &from_glib_borrow(clock),
         from_glib(time),
         &from_glib_borrow(id),
-    ).to_glib()
+    )
+    .to_glib()
 }
 
 unsafe extern "C" fn destroy_closure_wait_async(ptr: gpointer) {

gstreamer/src/event.rs

@@ -452,7 +452,8 @@ impl fmt::Debug for EventRef {
             .field("type", &unsafe {
                 let type_ = ffi::gst_event_type_get_name((*self.as_ptr()).type_);
                 CStr::from_ptr(type_).to_str().unwrap()
-            }).field("seqnum", &self.get_seqnum())
+            })
+            .field("seqnum", &self.get_seqnum())
             .field("structure", &self.get_structure())
             .finish()
     }

gstreamer/src/ghost_pad.rs

@@ -40,7 +40,8 @@ impl GhostPad {
                 name.0,
                 target.to_glib_none().0,
                 templ.to_glib_none().0,
-            )).map(|o| Downcast::downcast_unchecked(o))
+            ))
+            .map(|o| Downcast::downcast_unchecked(o))
         }
     }
 

gstreamer/src/iterator.rs

@@ -384,7 +384,8 @@ unsafe extern "C" fn filter_boxed_get_type<T: StaticType + 'static>() -> glib_ff
                     "GstRsIteratorFilterBoxed-{}-{}",
                     T::static_type().name(),
                     idx
-                )).unwrap();
+                ))
+                .unwrap();
                 if gobject_ffi::g_type_from_name(type_name.as_ptr()) == gobject_ffi::G_TYPE_INVALID
                 {
                     break type_name;

gstreamer/src/message.rs

@@ -348,7 +348,8 @@ impl fmt::Debug for MessageRef {
             .field("type", &unsafe {
                 let type_ = ffi::gst_message_type_get_name((*self.as_ptr()).type_);
                 CStr::from_ptr(type_).to_str().unwrap()
-            }).field("seqnum", &self.get_seqnum())
+            })
+            .field("seqnum", &self.get_seqnum())
             .field("src", &self.get_src().map(|s| s.get_name()))
             .field("structure", &self.get_structure())
             .finish()
@@ -1092,7 +1093,8 @@ impl<'a> StreamsSelected<'a> {
                         self.as_mut_ptr(),
                         i,
                     ))
-                }).collect()
+                })
+                .collect()
         }
     }
 }
@@ -1129,7 +1131,8 @@ impl<'a> Redirect<'a> {
                         from_glib_none(tags),
                         structure,
                     )
-                }).collect()
+                })
+                .collect()
         }
     }
 }

gstreamer/src/object.rs

@@ -60,7 +60,8 @@ impl<O: IsA<::Object> + IsA<glib::Object> + glib::value::SetValue> GstObjectExtM
             f(&obj, &prop_obj, &pspec);
 
             None
-        }).unwrap()
+        })
+        .unwrap()
     }
 }
 

gstreamer/src/pad.rs

@@ -1023,7 +1023,8 @@ unsafe extern "C" fn trampoline_activatemode_function(
         &from_glib_borrow(parent),
         from_glib(mode),
         from_glib(active),
-    ).to_glib()
+    )
+    .to_glib()
 }
 
 unsafe extern "C" fn trampoline_chain_function(
@@ -1041,7 +1042,8 @@ unsafe extern "C" fn trampoline_chain_function(
         &from_glib_borrow(pad),
         &from_glib_borrow(parent),
         from_glib_full(buffer),
-    ).to_glib()
+    )
+    .to_glib()
 }
 
 unsafe extern "C" fn trampoline_chain_list_function(
@@ -1059,7 +1061,8 @@ unsafe extern "C" fn trampoline_chain_list_function(
         &from_glib_borrow(pad),
         &from_glib_borrow(parent),
         from_glib_full(list),
-    ).to_glib()
+    )
+    .to_glib()
 }
 
 unsafe extern "C" fn trampoline_event_function(
@@ -1075,7 +1078,8 @@ unsafe extern "C" fn trampoline_event_function(
         &from_glib_borrow(pad),
         &from_glib_borrow(parent),
         from_glib_full(event),
-    ).to_glib()
+    )
+    .to_glib()
 }
 
 unsafe extern "C" fn trampoline_event_full_function(
@@ -1093,7 +1097,8 @@ unsafe extern "C" fn trampoline_event_full_function(
         &from_glib_borrow(pad),
         &from_glib_borrow(parent),
         from_glib_full(event),
-    ).to_glib()
+    )
+    .to_glib()
 }
 
 unsafe extern "C" fn trampoline_getrange_function(
@@ -1154,7 +1159,8 @@ unsafe extern "C" fn trampoline_link_function(
         &from_glib_borrow(pad),
         &from_glib_borrow(parent),
         &from_glib_borrow(peer),
-    ).to_glib()
+    )
+    .to_glib()
 }
 
 unsafe extern "C" fn trampoline_query_function(
@@ -1172,7 +1178,8 @@ unsafe extern "C" fn trampoline_query_function(
         &from_glib_borrow(pad),
         &from_glib_borrow(parent),
         ::QueryRef::from_mut_ptr(query),
-    ).to_glib()
+    )
+    .to_glib()
 }
 
 unsafe extern "C" fn trampoline_unlink_function(
@@ -1276,7 +1283,8 @@ mod tests {
                 sender.send(i).unwrap();
                 pad_clone.pause_task().unwrap();
             }
-        }).unwrap();
+        })
+        .unwrap();
 
         assert_eq!(receiver.recv().unwrap(), 3);
     }

gstreamer/src/query.rs

@@ -209,7 +209,8 @@ impl fmt::Debug for QueryRef {
             .field("type", &unsafe {
                 let type_ = ffi::gst_query_type_get_name((*self.as_ptr()).type_);
                 CStr::from_ptr(type_).to_str().unwrap()
-            }).field("structure", &self.get_structure())
+            })
+            .field("structure", &self.get_structure())
             .finish()
     }
 }

gstreamer/src/sample_serde.rs

@@ -173,7 +173,8 @@ mod tests {
                 "        (\"f3\", \"i32\", 123),",
                 "    ])),",
                 ")"
-            ).to_owned()),
+            )
+            .to_owned()),
             res
         );
 
@@ -225,7 +226,8 @@ mod tests {
                 "    )),",
                 "    info: None,",
                 ")"
-            ).to_owned()),
+            )
+            .to_owned()),
             res
         );
     }

gstreamer/src/segment_serde.rs

@@ -158,7 +158,8 @@ mod tests {
                 "    position: 256,",
                 "    duration: -1,",
                 ")"
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
     }

gstreamer/src/structure_serde.rs

@@ -197,7 +197,8 @@ mod tests {
                 "        (\"i32\", 2),",
                 "    ]),",
                 "])"
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
     }
@@ -229,7 +230,8 @@ mod tests {
                     ("fraction", &Fraction::new(1, 2)),
                     ("array", &Array::new(&[&1, &2])),
                 ],
-            ).as_ref()
+            )
+            .as_ref()
         );
     }
 

gstreamer/src/tags_serde.rs

@@ -336,7 +336,8 @@ mod tests {
                 "        ),",
                 "    ]),",
                 "]",
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
     }

gstreamer/src/toc_serde.rs

@@ -268,7 +268,8 @@ mod tests {
                 "        ),",
                 "    ],",
                 ")",
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
     }

gstreamer/src/typefind.rs

@@ -248,8 +248,10 @@ mod tests {
                         c.get_structure(0)
                             .map(|s| s.get_name() == "application/xml")
                             .unwrap_or(false)
-                    }).unwrap_or(false)
+                    })
-            }).unwrap();
+                    .unwrap_or(false)
+            })
+            .unwrap();
 
         let data = b"<?xml version=\"1.0\"?><test>test</test>";
         let data = &data[..];

gstreamer/src/value_serde.rs

@@ -348,7 +348,8 @@ mod tests {
                 "    (\"Fraction\", (1, 2)),",
                 "    (\"String\", \"test str\"),",
                 "]"
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
 
@@ -374,7 +375,8 @@ mod tests {
                 "    (\"Fraction\", (1, 2)),",
                 "    (\"String\", \"test str\"),",
                 "]"
-            ).to_owned()),
+            )
+            .to_owned()),
             res,
         );
     }

tutorials/src/bin/basic-tutorial-4.rs

@@ -82,7 +82,8 @@ fn tutorial_main() {
                             .seek_simple(
                                 gst::SeekFlags::FLUSH | gst::SeekFlags::KEY_UNIT,
                                 30 * gst::SECOND,
-                            ).expect("Failed to seek.");
+                            )
+                            .expect("Failed to seek.");
                         custom_data.seek_done = true;
                     }
                 }
@@ -114,35 +115,37 @@ fn handle_message(custom_data: &mut CustomData, msg: &gst::GstRc<gst::MessageRef
             // The duration has changed, mark the current one as invalid
             custom_data.duration = gst::CLOCK_TIME_NONE;
         }
-        MessageView::StateChanged(state_changed) => if state_changed
+        MessageView::StateChanged(state_changed) => {
-            .get_src()
+            if state_changed
-            .map(|s| s == custom_data.playbin)
+                .get_src()
-            .unwrap_or(false)
+                .map(|s| s == custom_data.playbin)
-        {
+                .unwrap_or(false)
-            let new_state = state_changed.get_current();
+            {
-            let old_state = state_changed.get_old();
+                let new_state = state_changed.get_current();
+                let old_state = state_changed.get_old();
 
-            println!(
+                println!(
-                "Pipeline state changed from {:?} to {:?}",
+                    "Pipeline state changed from {:?} to {:?}",
-                old_state, new_state
+                    old_state, new_state
-            );
+                );
 
-            custom_data.playing = new_state == gst::State::Playing;
+                custom_data.playing = new_state == gst::State::Playing;
-            if custom_data.playing {
+                if custom_data.playing {
-                let mut seeking = gst::Query::new_seeking(gst::Format::Time);
+                    let mut seeking = gst::Query::new_seeking(gst::Format::Time);
-                if custom_data.playbin.query(&mut seeking) {
+                    if custom_data.playbin.query(&mut seeking) {
-                    let (seekable, start, end) = seeking.get_result();
+                        let (seekable, start, end) = seeking.get_result();
-                    custom_data.seek_enabled = seekable;
+                        custom_data.seek_enabled = seekable;
-                    if seekable {
+                        if seekable {
-                        println!("Seeking is ENABLED from {:?} to {:?}", start, end)
+                            println!("Seeking is ENABLED from {:?} to {:?}", start, end)
+                        } else {
+                            println!("Seeking is DISABLED for this stream.")
+                        }
                     } else {
-                        println!("Seeking is DISABLED for this stream.")
+                        eprintln!("Seeking query failed.")
                     }
-                } else {
-                    eprintln!("Seeking query failed.")
                 }
             }
-        },
+        }
         _ => (),
     }
 }

tutorials/src/bin/basic-tutorial-5.rs

@@ -50,35 +50,43 @@ mod tutorial5 {
         let signame: &str = &format!("get-{}-tags", stype);
 
         match playbin.get_property(propname).unwrap().get() {
-            Some(x) => for i in 0..x {
+            Some(x) => {
-                let tags = playbin.emit(signame, &[&i]).unwrap().unwrap();
+                for i in 0..x {
+                    let tags = playbin.emit(signame, &[&i]).unwrap().unwrap();
 
-                if let Some(tags) = tags.get::<gst::TagList>() {
+                    if let Some(tags) = tags.get::<gst::TagList>() {
-                    textbuf.insert_at_cursor(&format!("{} stream {}:\n ", stype, i));
+                        textbuf.insert_at_cursor(&format!("{} stream {}:\n ", stype, i));
 
-                    if let Some(codec) = tags.get::<gst::tags::VideoCodec>() {
+                        if let Some(codec) = tags.get::<gst::tags::VideoCodec>() {
-                        textbuf
+                            textbuf.insert_at_cursor(&format!(
-                            .insert_at_cursor(&format!("    codec: {} \n", codec.get().unwrap()));
+                                "    codec: {} \n",
-                    }
+                                codec.get().unwrap()
+                            ));
+                        }
 
-                    if let Some(codec) = tags.get::<gst::tags::AudioCodec>() {
+                        if let Some(codec) = tags.get::<gst::tags::AudioCodec>() {
-                        textbuf
+                            textbuf.insert_at_cursor(&format!(
-                            .insert_at_cursor(&format!("    codec: {} \n", codec.get().unwrap()));
+                                "    codec: {} \n",
-                    }
+                                codec.get().unwrap()
+                            ));
+                        }
 
-                    if let Some(lang) = tags.get::<gst::tags::LanguageCode>() {
+                        if let Some(lang) = tags.get::<gst::tags::LanguageCode>() {
-                        textbuf
+                            textbuf.insert_at_cursor(&format!(
-                            .insert_at_cursor(&format!("    language: {} \n", lang.get().unwrap()));
+                                "    language: {} \n",
-                    }
+                                lang.get().unwrap()
+                            ));
+                        }
 
-                    if let Some(bitrate) = tags.get::<gst::tags::Bitrate>() {
+                        if let Some(bitrate) = tags.get::<gst::tags::Bitrate>() {
-                        textbuf.insert_at_cursor(&format!(
+                            textbuf.insert_at_cursor(&format!(
-                            "    bitrate: {} \n",
+                                "    bitrate: {} \n",
-                            bitrate.get().unwrap()
+                                bitrate.get().unwrap()
-                        ));
+                            ));
+                        }
                     }
                 }
-            },
+            }
             None => {
                 eprintln!("Could not get {}!", propname);
             }
@@ -328,21 +336,24 @@ mod tutorial5 {
                 let pipeline = args[0].get::<gst::Element>().unwrap();
                 post_app_message(&pipeline);
                 None
-            }).unwrap();
+            })
+            .unwrap();
 
         playbin
             .connect("audio-tags-changed", false, |args| {
                 let pipeline = args[0].get::<gst::Element>().unwrap();
                 post_app_message(&pipeline);
                 None
-            }).unwrap();
+            })
+            .unwrap();
 
         playbin
             .connect("text-tags-changed", false, move |args| {
                 let pipeline = args[0].get::<gst::Element>().unwrap();
                 post_app_message(&pipeline);
                 None
-            }).unwrap();
+            })
+            .unwrap();
 
         let window = create_ui(&playbin);
 

tutorials/src/bin/basic-tutorial-7.rs

@@ -40,7 +40,8 @@ fn tutorial_main() {
             &visual,
             &video_convert,
             &video_sink,
-        ]).unwrap();
+        ])
+        .unwrap();
 
     gst::Element::link_many(&[&audio_source, &tee]).unwrap();
     gst::Element::link_many(&[&audio_queue, &audio_convert, &audio_resample, &audio_sink]).unwrap();

tutorials/src/bin/basic-tutorial-8.rs

@@ -86,7 +86,8 @@ fn main() {
             &video_sink,
             &app_queue,
             &appsink,
-        ]).unwrap();
+        ])
+        .unwrap();
 
     gst::Element::link_many(&[&appsrc, &tee]).unwrap();
     gst::Element::link_many(&[&audio_queue, &audio_convert1, &audio_resample, &audio_sink])
@@ -97,7 +98,8 @@ fn main() {
         &visual,
         &video_convert,
         &video_sink,
-    ]).unwrap();
+    ])
+    .unwrap();
     gst::Element::link_many(&[&app_queue, &appsink]).unwrap();
 
     let tee_audio_pad = tee.get_request_pad("src_%u").unwrap();