About Streaming

[lazhenyi]

Hello, we are going to use your crate to build a distributed file system. Streaming is very important in this part, but I regret not seeing any relevant examples. I would be very happy if there were any. Thank you very much.

[surban]

Could you specify what kind of streaming example you would like?

[lazhenyi]

Could you specify what kind of streaming example you would like?

refer to

   let mut cmd = Command::new("**");
   cmd.stdout(Stdio::piped());
    let mut process = match cmd.spawn() {
          Ok(process) => process,
          Err(e) => {
              info!("Error running command: {}", e);
              return Err(anyhow::anyhow!("Error running command"));
          }
      };
   let mut stdout = process.stdout.take().unwrap();


   let stream:AsyncStream<Result<bytes::Bytes, io::Error>, impl Future<Output=()>+Sized> = stream! {
            let mut buffer = [0; 8192];
            loop {
                match stdout.read(&mut buffer) {
                    Ok(0) => break, // EOF
                    Ok(n) => yield Ok::<_, io::Error>(bytes::Bytes::copy_from_slice(&buffer[..n])),
                    Err(e) => {
                        eprintln!("Error reading stdout: {}", e);
                        break;
                    }
                }
            }
        };

At this time, I want to use stream as the transmission content. How should I operate here? I am confused.