gistfile1.txt

// implement a Connector that does nothing
#[derive(Debug)]
pub struct NoConnector {
    pub stream: TcpStream
}

impl NoConnector {
    pub fn new(stream: TcpStream) -> Self {
        NoConnector { stream }
    }
}

impl<In: Transport> Connector<In> for NoConnector {
    type Out = Either<In, TcpTransport>;

    fn connect(
        &self,
        details: &ConnectionDetails,
        _chained: Option<In>,
    ) -> Result<Option<Self::Out>, Error> {

        let config = &details.config;
        let buffers = LazyBuffers::new(config.input_buffer_size(), config.output_buffer_size());
        let transport = TcpTransport::new(self.stream.try_clone().unwrap(), buffers);
        //debug!("connected");

        Ok(Some(Either::B(transport)))
    }
}