Explicit impl Clone for tx to avoid T: Clone

tokio-sync/src/mpsc/bounded.rs

@@ -7,11 +7,17 @@ use std::fmt;
 /// Send values to the associated `Receiver`.
 ///
 /// Instances are created by the [`channel`](fn.channel.html) function.
-#[derive(Debug, Clone)]
+#[derive(Debug)]
 pub struct Sender<T> {
     chan: chan::Tx<T, Semaphore>,
 }
 
+impl<T> Clone for Sender<T> {
+    fn clone(&self) -> Self {
+        Sender { chan: self.chan.clone() }
+    }
+}
+
 /// Receive values from the associated `Sender`.
 ///
 /// Instances are created by the [`channel`](fn.channel.html) function.

tokio-sync/src/mpsc/unbounded.rs

@@ -9,11 +9,17 @@ use std::fmt;
 ///
 /// Instances are created by the
 /// [`unbounded_channel`](fn.unbounded_channel.html) function.
-#[derive(Debug, Clone)]
+#[derive(Debug)]
 pub struct UnboundedSender<T> {
     chan: chan::Tx<T, Semaphore>,
 }
 
+impl<T> Clone for UnboundedSender<T> {
+    fn clone(&self) -> Self {
+        UnboundedSender { chan: self.chan.clone() }
+    }
+}
+
 /// Receive values from the associated `UnboundedSender`.
 ///
 /// Instances are created by the

tokio-sync/tests/mpsc.rs

@@ -91,6 +91,36 @@ fn send_recv_unbounded() {
     assert!(val.is_none());
 }
 
+#[test]
+fn clone_sender_no_t_clone_buffer() {
+    #[derive(Debug, PartialEq, Eq)]
+    struct NotClone;
+    let (mut tx, mut rx) = mpsc::channel(100);
+    tx.try_send(NotClone).unwrap();
+    tx.clone().try_send(NotClone).unwrap();
+
+    let val = assert_ready!(rx.poll());
+    assert_eq!(val, Some(NotClone));
+
+    let val = assert_ready!(rx.poll());
+    assert_eq!(val, Some(NotClone));
+}
+
+#[test]
+fn clone_sender_no_t_clone_unbounded() {
+    #[derive(Debug, PartialEq, Eq)]
+    struct NotClone;
+    let (mut tx, mut rx) = mpsc::unbounded_channel();
+    tx.try_send(NotClone).unwrap();
+    tx.clone().try_send(NotClone).unwrap();
+
+    let val = assert_ready!(rx.poll());
+    assert_eq!(val, Some(NotClone));
+
+    let val = assert_ready!(rx.poll());
+    assert_eq!(val, Some(NotClone));
+}
+
 #[test]
 fn send_recv_buffer_limited() {
     let (mut tx, mut rx) = mpsc::channel::<i32>(1);