Is there any problem with my code and why it doesn't work

[pysrc]

use futures::{future, stream, AsyncReadExt, AsyncWriteExt, StreamExt};
use tokio::net::{TcpListener, TcpStream};
use tokio_util::compat::TokioAsyncReadCompatExt;

#[tokio::main]
async fn main() {
    
    tokio::spawn(async move {
        let lis = TcpListener::bind("0.0.0.0:8000").await.unwrap();
        let (conn, _) = lis.accept().await.unwrap();
        let muxcfg = yamux::Config::default();
        let mut c = yamux::Connection::new(conn.compat(), muxcfg, yamux::Mode::Server);
        println!("111");
        let mut server = stream::poll_fn(move |cx| c.poll_next_inbound(cx));
        let mut stream = server.next().await.unwrap().unwrap();
        println!("xxxx");
        let mut buf = [0u8; 1024];
        let n = stream.read(&mut buf).await.unwrap();
        let s = String::from_utf8_lossy(&buf[..n]).to_string();
        println!("{}", s);
        stream.close().await.unwrap();
        println!("s2");
        let mut stream = server.next().await.unwrap().unwrap();
        let mut buf = [0u8; 1024];
        let n = stream.read(&mut buf).await.unwrap();
        let s = String::from_utf8_lossy(&buf[..n]).to_string();
        println!("{}", s);
        stream.close().await.unwrap();
        println!("999");
    });
    tokio::spawn(async move {
        let s = TcpStream::connect("127.0.0.1:8000").await.unwrap();
        let muxcfg = yamux::Config::default();
        let mut c = yamux::Connection::new(s.compat(), muxcfg, yamux::Mode::Client);
        let mut stream = future::poll_fn(|cx| c.poll_new_outbound(cx)).await.unwrap();
        stream
            .write_all("Hello World! 1\n".as_bytes())
            .await
            .unwrap();
        stream.flush().await.unwrap();
        stream.close().await.unwrap();
        println!("send 2");
        let mut stream = future::poll_fn(|cx| c.poll_new_outbound(cx)).await.unwrap();
        stream
            .write_all("Hello World! 2\n".as_bytes())
            .await
            .unwrap();
        stream.flush().await.unwrap();
        stream.close().await.unwrap();
        tokio::time::sleep(tokio::time::Duration::from_secs(100)).await;
    });
    tokio::time::sleep(tokio::time::Duration::from_secs(100)).await;
}

[thomaseizinger]

Yes. You need to continously call poll_next_inbound for streams to make progress.

This yamux implementation does not have any implicit background tasks but the streams are just connected to the Connection via channels. If you don't poll the connection, those channels are never read from and thus no data is sent to the network.

[thomaseizinger]

You probably want to write yourself your own eventloop that houses the Connection and sends Streams to your app via channels.

[pysrc]

You probably want to write yourself your own eventloop that houses the Connection and sends Streams to your app via channels.

Can you make some changes based on my code? I have tried many ways, but it still doesn't work.

[thomaseizinger]

You probably want to write yourself your own eventloop that houses the Connection and sends Streams to your app via channels.

Can you make some changes based on my code? I have tried many ways, but it still doesn't work.

Sorry, don't have the capacity for that! Have you had a look at the tests in this repository?

[caelansar]

Please refer to this code