rust.rs

    pub fn with_discovery(&mut self, mechanisms: Vec<impl Stream<Item = SocketAddr>>) {
        let stream = mechanisms
            .into_iter()
            .fold(stream::pending(), |init, item| init.merge(item));
             /// mismatched types
            /// expected struct `async_std::stream::pending::Pending<_>`
            /// found struct `async_std::stream::stream::merge::Merge<async_std::stream::pending::Pending<_>, impl Stream<Item = SocketAddr>>`

    }

    pub fn with_discovery_iter(&mut self, mechanisms: Vec<impl Stream<Item = SocketAddr>>) {
        let stream = stream::pending();
        for item in mechanisms {
            stream = stream.merge(item);
            /// mismatched types
            /// expected struct `async_std::stream::pending::Pending<_>`
            /// found struct `async_std::stream::stream::merge::Merge<async_std::stream::pending::Pending<_>, impl Stream<Item = SocketAddr>>`
        }
    }