Function stream 

pub fn stream<T: Into<Bytes>>() -> (Sender<T>, impl Body<Data = Bytes, Error = Error>)

Available on crate feature http only.

Create a streaming body, with a Sender for writing to the body. This supports strings, Bytes, Vec<u8>, and any IntoIterator<Item = u8>. For types which are not Into<Bytes>, use stream_any.

Examples

use futures::SinkExt;

let (mut tx, body) = stream::<String>();

spin_sdk::wasip3::spawn(async move {
    for i in 0..10000 {
        if tx.send(format!("{i}\n")).await.is_err() {
            break;
        }
    }
});

let response = Response::new(body);