Enum Reply 

pub enum Reply {
    Outcome(Result<Outcome, ErrorReport>),
    Stream(StreamEvents),
}

An answer, or an owned stream whose execution belongs to the driver.

Variants

Outcome(Result<Outcome, ErrorReport>)

The completed unary answer or a setup error.

Stream(StreamEvents)

Events, including any frames after the first terminal record.

Implementations

impl Reply

pub async fn into_outcome(self) -> Result<Outcome, ErrorReport>

Fold a stream to its first outcome, or return the unary answer.

pub fn into_stream(self) -> StreamEvents

Convert a completion into its events, then the response; incompatible outcomes become errors.

impl Reply

pub fn written<F, Fut>(write: F) -> Self

where F: FnOnce(StreamWriter) -> Fut, Fut: Future<Output = ()> + WasmCompatSend + 'static,

Return a stream that owns and polls the writing future alongside its private receiver. No task is spawned. The bridge has zero shared capacity and one sender-reserved slot; it is not a rendezvous channel. Dropping the returned stream drops the writing future and receiver.