Implement ToOwned for Message/Event/QueryRef

gstreamer/src/event.rs

@@ -372,6 +372,17 @@ impl glib::types::StaticType for EventRef {
     }
 }
 
+impl ToOwned for EventRef {
+    type Owned = GstRc<EventRef>;
+
+    fn to_owned(&self) -> GstRc<EventRef> {
+        unsafe {
+            from_glib_full(ffi::gst_mini_object_copy(self.as_ptr() as *const _)
+                as *mut _)
+        }
+    }
+}
+
 pub enum EventView<'a> {
     FlushStart(FlushStart<'a>),
     FlushStop(FlushStop<'a>),

gstreamer/src/message.rs

@@ -346,6 +346,17 @@ impl glib::types::StaticType for MessageRef {
     }
 }
 
+impl ToOwned for MessageRef {
+    type Owned = GstRc<MessageRef>;
+
+    fn to_owned(&self) -> GstRc<MessageRef> {
+        unsafe {
+            from_glib_full(ffi::gst_mini_object_copy(self.as_ptr() as *const _)
+                as *mut _)
+        }
+    }
+}
+
 pub enum MessageView<'a> {
     Eos(Eos<'a>),
     Error(Error<'a>),

gstreamer/src/query.rs

@@ -182,6 +182,17 @@ impl glib::types::StaticType for QueryRef {
     }
 }
 
+impl ToOwned for QueryRef {
+    type Owned = GstRc<QueryRef>;
+
+    fn to_owned(&self) -> GstRc<QueryRef> {
+        unsafe {
+            from_glib_full(ffi::gst_mini_object_copy(self.as_ptr() as *const _)
+                as *mut _)
+        }
+    }
+}
+
 pub enum QueryView<T> {
     Position(Position<T>),
     Duration(Duration<T>),