Remove `IntoSender`

1 files changed, 0 insertions, 85 deletions

diff --git a/talpid-core/src/mpsc.rs b/talpid-core/src/mpsc.rs
index c3974c70be..050b90c81c 100644
--- a/talpid-core/src/mpsc.rs
+++ b/talpid-core/src/mpsc.rs
@@ -1,90 +1,5 @@
-use futures::sync::mpsc::UnboundedSender;
-use std::marker::PhantomData;
-
 /// Abstraction over any type that can be used similarly to an `std::mpsc::Sender`.
 pub trait Sender<T> {
     /// Sends an item over the underlying channel, failing only if the channel is closed.
     fn send(&self, item: T) -> Result<(), ()>;
 }
-
-/// Abstraction over an `mpsc::Sender` that first converts the value to another type before sending.
-#[derive(Debug, Clone)]
-pub struct IntoSender<T, U> {
-    sender: UnboundedSender<U>,
-    _marker: PhantomData<T>,
-}
-
-impl<T, U> Sender<T> for IntoSender<T, U>
-where
-    T: Into<U>,
-{
-    /// Converts the `T` into a `U` and sends it on the channel.
-    fn send(&self, item: T) -> Result<(), ()> {
-        self.sender.unbounded_send(item.into()).map_err(|_| ())
-    }
-}
-
-impl<T, U> From<UnboundedSender<U>> for IntoSender<T, U>
-where
-    T: Into<U>,
-{
-    fn from(sender: UnboundedSender<U>) -> Self {
-        IntoSender {
-            sender,
-            _marker: PhantomData,
-        }
-    }
-}
-
-#[cfg(test)]
-mod tests {
-    use super::*;
-    use futures::{sync::mpsc, Stream};
-    use std::thread;
-
-    #[derive(Debug, Eq, PartialEq)]
-    enum Inner {
-        One,
-        Two,
-    }
-
-    #[derive(Debug, Eq, PartialEq)]
-    enum Outer {
-        Inner(Inner),
-        Other,
-    }
-
-    impl From<Inner> for Outer {
-        fn from(o: Inner) -> Self {
-            Outer::Inner(o)
-        }
-    }
-
-    #[test]
-    fn sender() {
-        let (tx, rx) = mpsc::unbounded();
-        let inner_tx: IntoSender<Inner, Outer> = tx.clone().into();
-
-        tx.unbounded_send(Outer::Other).unwrap();
-        inner_tx.send(Inner::Two).unwrap();
-
-        let mut sync_rx = rx.wait();
-
-        assert_eq!(Outer::Other, sync_rx.next().unwrap().unwrap());
-        assert_eq!(Outer::Inner(Inner::Two), sync_rx.next().unwrap().unwrap());
-    }
-
-    #[test]
-    fn send_between_thread() {
-        let (tx, rx) = mpsc::unbounded();
-        let inner_tx: IntoSender<Inner, Outer> = tx.clone().into();
-
-        thread::spawn(move || {
-            inner_tx.send(Inner::One).unwrap();
-        });
-
-        let mut sync_rx = rx.wait();
-
-        assert_eq!(Outer::Inner(Inner::One), sync_rx.next().unwrap().unwrap());
-    }
-}