Add trait functions for getting back the controller

src/rsfilesink.rs

@@ -62,6 +62,10 @@ impl FileSink {
 }
 
 impl Sink for FileSink {
+    fn get_controller(&self) -> &SinkController {
+        &self.controller
+    }
+
     fn set_uri(&self, uri: Option<Url>) -> Result<(), (UriError, String)> {
         let location = &mut self.settings.lock().unwrap().location;
 

src/rsfilesrc.rs

@@ -63,6 +63,10 @@ impl FileSrc {
 }
 
 impl Source for FileSrc {
+    fn get_controller(&self) -> &SourceController {
+        &self.controller
+    }
+
     fn set_uri(&self, uri: Option<Url>) -> Result<(), (UriError, String)> {
         let location = &mut self.settings.lock().unwrap().location;
 

src/rshttpsrc.rs

@@ -141,6 +141,10 @@ impl HttpSrc {
 }
 
 impl Source for HttpSrc {
+    fn get_controller(&self) -> &SourceController {
+        &self.controller
+    }
+
     fn set_uri(&self, uri: Option<Url>) -> Result<(), (UriError, String)> {
         let url = &mut self.settings.lock().unwrap().url;
 

src/rssink.rs

@@ -38,6 +38,8 @@ impl SinkController {
 }
 
 pub trait Sink: Sync + Send {
+    fn get_controller(&self) -> &SinkController;
+
     // Called from any thread at any time
     fn set_uri(&self, uri: Option<Url>) -> Result<(), (UriError, String)>;
     fn get_uri(&self) -> Option<Url>;

src/rssource.rs

@@ -37,6 +37,8 @@ impl SourceController {
 }
 
 pub trait Source: Sync + Send {
+    fn get_controller(&self) -> &SourceController;
+
     // Called from any thread at any time
     fn set_uri(&self, uri: Option<Url>) -> Result<(), (UriError, String)>;
     fn get_uri(&self) -> Option<Url>;