Function workflow_wasm::stream::create_async_stream_iterator

source ·

pub fn create_async_stream_iterator<T>(
    source: impl Stream<Item = T> + Send + 'static
) -> JsValuewhere
    T: Into<JsValue> + Send + 'static,

Expand description

Helper function that receives a stream and returns a JsValue representing the JavaScript generator iterating this stream. The function uses AsyncStream internally as follows: AsyncStream::new(stream).into()