How to implement an async read/write incoming stream with tokio named pipe?

Hi all.

I'd like to know how could I implement an incoming stream with async read/write [`tokio::net::windows::named_pipe`](https://docs.rs/tokio/latest/tokio/net/windows/named_pipe/index.html)?

I'm new to tokio and tonic, and my use case requires me to use Windows named pipe as the gRPC backend transport.

I know the named pipe stream has to implement the `futures::stream::Stream` trait (i.e. the `poll_next` method), but I have no idea of how to write the working code.

Do you guys have any hint for this?