shane/thrussh - Change 63PFETNDJ7MIPCUKAQ5LXQ6DMADU6MXFCMKA2XLSP4DELKTPNEFAC

fix compile errors in tests and examples

Created by ubnt-intrepid on January 10, 2021

63PFETNDJ7MIPCUKAQ5LXQ6DMADU6MXFCMKA2XLSP4DELKTPNEFAC

Dependencies

In channels

main

Change contents

Replacement in thrussh-keys/src/lib.rs at line 747 [3.21590]

B:BD[3.54966] → [3.54966:55035]

            let (_, buf) = client.sign_request(&public, buf).await?;

[3.54966]

[3.55035]

            let (_, buf) = client.sign_request(&public, buf).await;
            let buf = buf?;

Replacement in thrussh-keys/src/lib.rs at line 799 [3.21590]

B:BD[3.56531] → [3.56531:56597]

            agent::server::serve(listener.incoming(), X {}).await

[3.56531]

[3.56597]

            agent::server::serve(
                Incoming {
                    listener: &mut listener,
                },
                X {},
            )
            .await

Replacement in thrussh-keys/src/lib.rs at line 818 [3.21590]

B:BD[3.57200] → [3.57200:57269]

            let (_, buf) = client.sign_request(&public, buf).await?;

[3.57200]

[3.57269]

            let (_, buf) = client.sign_request(&public, buf).await;
            let buf = buf?;

Insertion in thrussh-keys/src/lib.rs at line 826 [3.21590]

[3.57439]


    struct Incoming<'a> {
        listener: &'a mut tokio::net::UnixListener,
    }
    impl futures::stream::Stream for Incoming<'_> {
        type Item = Result<tokio::net::UnixStream, std::io::Error>;
        fn poll_next(
            self: std::pin::Pin<&mut Self>,
            cx: &mut std::task::Context<'_>,
        ) -> std::task::Poll<Option<Self::Item>> {
            let (sock, _addr) = futures::ready!(self.get_mut().listener.poll_accept(cx))?;
            std::task::Poll::Ready(Some(Ok(sock)))
        }
    }

Replacement in thrussh/examples/client.rs at line 46 [2.24]

B:BD[2.1441] → [2.1441:1475]

        .await
        .unwrap();

[2.1441]

[2.1475]

        .await;
    let auth_res = auth_res.unwrap();