Merge pull request #9 from abonander/master

Manually implement `Clone` for `MPMCFut*` types

Author: schets

src/mpmc.rs

@@ -85,14 +85,12 @@ pub struct MPMCUniReceiver<T> {
 
 /// This is the futures-compatible version of ```MPMCSender```
 /// It implements Sink
-#[derive(Clone)]
 pub struct MPMCFutSender<T> {
     sender: FutInnerSend<MPMC<T>, T>,
 }
 
 /// This is the futures-compatible version of ```MPMCReceiver```
 /// It implements Stream
-#[derive(Clone)]
 pub struct MPMCFutReceiver<T> {
     receiver: FutInnerRecv<MPMC<T>, T>,
 }
@@ -512,6 +510,14 @@ impl<R, F: FnMut(&T) -> R, T> MPMCFutUniReceiver<R, F, T> {
     }
 }
 
+impl<T> Clone for MPMCFutSender<T> {
+    fn clone(&self) -> Self {
+        MPMCFutSender {
+            sender: self.sender.clone(),
+        }
+    }
+}
+
 impl<T> Sink for MPMCFutSender<T> {
     type SinkItem = T;
     type SinkError = SendError<T>;
@@ -527,6 +533,14 @@ impl<T> Sink for MPMCFutSender<T> {
     }
 }
 
+impl<T> Clone for MPMCFutReceiver<T> {
+    fn clone(&self) -> Self {
+        MPMCFutReceiver {
+            receiver: self.receiver.clone(),
+        }
+    }
+}
+
 impl<T> Stream for MPMCFutReceiver<T> {
     type Item = T;
     type Error = ();

src/multiqueue.rs

@@ -180,15 +180,13 @@ pub struct InnerRecv<RW: QueueRW<T>, T> {
 }
 
 /// This is a sender that can transparently act as a futures stream
-#[derive(Clone)]
 pub struct FutInnerSend<RW: QueueRW<T>, T> {
     writer: InnerSend<RW, T>,
     wait: Arc<FutWait>,
     prod_wait: Arc<FutWait>,
 }
 
 /// This is a receiver that can transparently act as a futures stream
-#[derive(Clone)]
 pub struct FutInnerRecv<RW: QueueRW<T>, T> {
     reader: InnerRecv<RW, T>,
     wait: Arc<FutWait>,
@@ -973,6 +971,26 @@ impl<RW: QueueRW<T>, T> Clone for InnerRecv<RW, T> {
     }
 }
 
+impl<RW: QueueRW<T>, T> Clone for FutInnerSend<RW, T> {
+    fn clone(&self) -> FutInnerSend<RW, T> {
+        FutInnerSend {
+            writer: self.writer.clone(),
+            wait: self.wait.clone(),
+            prod_wait: self.prod_wait.clone(),
+        }
+    }
+}
+
+impl<RW: QueueRW<T>, T> Clone for FutInnerRecv<RW, T> {
+    fn clone(&self) -> FutInnerRecv<RW, T> {
+        FutInnerRecv {
+            reader: self.reader.clone(),
+            wait: self.wait.clone(),
+            prod_wait: self.prod_wait.clone(),
+        }
+    }
+}
+
 impl Clone for FutWait {
     fn clone(&self) -> FutWait {
         FutWait::with_spins(self.spins_first, self.spins_yield)