diff --git a/gstreamer/src/bus.rs b/gstreamer/src/bus.rs
index 07cab600e..02243cca8 100644
--- a/gstreamer/src/bus.rs
+++ b/gstreamer/src/bus.rs
@@ -81,7 +81,7 @@ impl Bus {
         name: N,
         priority: Priority,
         func: F,
-    ) -> Option<glib::Source>
+    ) -> glib::Source
     where
         F: FnMut(&Bus, &Message) -> Continue + Send + 'static,
     {