diff options
Diffstat (limited to 'components/canvas_traits/webgl_channel/mpsc.rs')
-rw-r--r-- | components/canvas_traits/webgl_channel/mpsc.rs | 51 |
1 files changed, 51 insertions, 0 deletions
diff --git a/components/canvas_traits/webgl_channel/mpsc.rs b/components/canvas_traits/webgl_channel/mpsc.rs new file mode 100644 index 00000000000..b0fe29241f3 --- /dev/null +++ b/components/canvas_traits/webgl_channel/mpsc.rs @@ -0,0 +1,51 @@ +/* This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ + +use serde::{Deserialize, Serialize}; +use serde::{Deserializer, Serializer}; +use std::sync::mpsc; + +#[macro_use] +macro_rules! unreachable_serializable { + ($name:ident) => { + impl<T> Serialize for $name<T> { + fn serialize<S: Serializer>(&self, _: S) -> Result<S::Ok, S::Error> { + unreachable!(); + } + } + + impl<'a, T> Deserialize<'a> for $name<T> { + fn deserialize<D>(_: D) -> Result<$name<T>, D::Error> + where D: Deserializer<'a> { + unreachable!(); + } + } + }; +} + +#[derive(Clone)] +pub struct WebGLSender<T>(mpsc::Sender<T>); +pub struct WebGLReceiver<T>(mpsc::Receiver<T>); + +impl<T> WebGLSender<T> { + #[inline] + pub fn send(&self, data: T) -> Result<(), mpsc::SendError<T>> { + self.0.send(data) + } +} + +impl<T> WebGLReceiver<T> { + #[inline] + pub fn recv(&self) -> Result<T, mpsc::RecvError> { + self.0.recv() + } +} + +pub fn webgl_channel<T>() -> Result<(WebGLSender<T>, WebGLReceiver<T>), ()> { + let (sender, receiver) = mpsc::channel(); + Ok((WebGLSender(sender), WebGLReceiver(receiver))) +} + +unreachable_serializable!(WebGLReceiver); +unreachable_serializable!(WebGLSender); |