Streaming protocol

[rgbkrk]

Is your feature request related to a problem? Please describe.

I'd love to have a way to push data to the webview in a streaming fashion, whether server sent events or websockets. This got discussed in #420, but is distinctly different as that issue was about asynchronously returning a singular response.

Describe the solution you'd like

Accept Response<Stream<Item = Vec<u8>>> in some manner.

Response (from http) can already accept a Stream

fn stream_response(
    _request: Request<Vec<u8>>,
) -> Result<Response<impl Stream<Item = Vec<u8>> + Send>> {
    let stream = futures::stream::iter(vec![
        "Hello ".as_bytes().to_vec(),
        "World".as_bytes().to_vec(),
    ]);

    Ok(Response::builder()
        .header("Content-Type", "text/plain")
        .status(200)
        .body(stream)
        .unwrap())
}

Where it goes awry is on response via the RequestAsyncResponder, which requires a Response<Into<Cow<'static, [u8]>>>.

[wadamek65]

Any updates on this? I'd be willing to give it a try to implement this as it seems it shouldn't be too complex of a change? @FabianLars

[FabianLars]

No updates. As far as I know, nobody's working on it, I for one didn't even look into it at all.
I also have no idea how to implement this tbh

[wadamek65]

No updates. As far as I know, nobody's working on it, I for one didn't even look into it at all. I also have no idea how to implement this tbh

Alright, thanks for the response. I'll tinker a little bit and see if I can handle this alone.