diff options
author | Anthony Ramine <n.oxyde@gmail.com> | 2017-08-16 23:23:18 +0200 |
---|---|---|
committer | Anthony Ramine <n.oxyde@gmail.com> | 2017-08-16 23:23:18 +0200 |
commit | 676f2c8acf6fec8ad77d4daa51bef5bdcae101c5 (patch) | |
tree | d212209744e3b10a315dc79da754a70d7543e428 /components/canvas_traits/webgl_channel/mpsc.rs | |
parent | 4d10d39e8fe841c5fe2ac58da2daaa13c10c140e (diff) | |
download | servo-676f2c8acf6fec8ad77d4daa51bef5bdcae101c5.tar.gz servo-676f2c8acf6fec8ad77d4daa51bef5bdcae101c5.zip |
Revert "Auto merge of #18114 - emilio:revert-webgl-refactor, r=nox"
This reverts commit 4d10d39e8fe841c5fe2ac58da2daaa13c10c140e, reversing
changes made to ee94e2b7c0bd327abe8f9545b2a1f792f67a2bdd.
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); |