Struct workflow_wasm::stream::AsyncStream

pub struct AsyncStream(_);

AsyncStream is a helper that receives a stream that must correspond to the following spec: Stream<Item = T> where T : Into<JsValue> + Send + 'static. The stream must be supplied via the AsyncStream::new constructor.

You can then use into() to obtain a JsValue the represents a JavaScript generator iterating this stream.

Implementations

impl AsyncStream

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

Trait Implementations

impl From<AsyncStream> for JsValue

fn from(stream: AsyncStream) -> Self

Converts to this type from the input type.