Struct Opened 

pub struct Opened<F> { /* private fields */ }

One reply a transport opened: its frames, and the facts the transport owns.

Implementations

impl<F: WasmCompatSend + 'static> Opened<F>

pub fn new( frames: impl Stream<Item = Result<F, ProviderError>> + WasmCompatSend + 'static, ) -> Self

A reply of frames, in order. A transport failure is the last item.

pub fn failed(error: ProviderError) -> Self

A reply that failed with error before any frame.

pub fn with_request_id(self, request_id: Option<String>) -> Self

The provider’s transport request id, when the reply carried one. An empty id is no id.

pub fn with_http(self, status: StatusCode, headers: HeaderMap) -> Self

The reply’s HTTP status and headers, which enrich its unary failure.

pub fn with_route(self, route: impl Into<String>) -> Self

The concrete request path, which a listing’s failure names.

pub fn with_document(self, document: Value) -> Self

The whole reply as one document: the response’s raw. A reply with one is not fed to the wire’s reassembler.

pub fn map_frames<S>( self, frames: impl FnOnce(WasmBoxedStream<'static, Result<F, ProviderError>>) -> S, ) -> Self

where S: Stream<Item = Result<F, ProviderError>> + WasmCompatSend + 'static,

The same reply, its frames passed through frames: what a transport that wraps another uses to watch or rewrite a reply in flight.