将通道接收器类型从Receiver<T>更改为Receiver<U>

Question

我有一个接口，它定义了一个返回接收器的方法：

pub fn subscribe(to: &str) -> crossbeam_channel::Receiver<Message>;

我使用的是一个库方法，它返回一个接收者，但消息类型不同：

pub fn subscribe(to: &str) -> crossbeam_channel::Receiver<lib::Message>;

将lib::Message转换为Message很容易，但是我如何实现接口，它将充当这个库的包装器，这样返回的类型就是正确的？

我尝试创建一个新通道，但这不起作用，(我认为)因为该方法将返回，然后不再向新通道传递消息，因此receiver将始终为空。

let sub_recv = subscription.receiver();
let (send, receiver) = crossbeam_channel::unbounded::<Message>();
for m in sub_recv.try_recv() {
    send.send(m.into()).map_err(|_| MQError::ConversionError)?;
}

谢谢

Answer 1

要在你的类型之间转换，你应该运行后台任务来做，因为否则你会阻塞你试图这样做的线程。

Playground link

use crossbeam_channel::{Receiver, unbounded}; // 0.5.0

trait ReceiverCompatExt<T>
{
    fn convert(self) -> Receiver<T>;
}

impl<T, U> ReceiverCompatExt<U> for Receiver<T>
    where U: From<T>,
          T: Send + 'static,
          U: Send + 'static,
{
    fn convert(self) -> Receiver<U> {
        let (sender, receiver) = unbounded();
        
        std::thread::spawn(move || {
            while let Ok(value) = self.recv() {
                if sender.send(value.into()).is_err() {
                    break;
                }
            }
        });
        
        receiver
    }
}