Struct RemoteTransport 

pub struct RemoteTransport { /* private fields */ }

A network-backed transport that connects a runtime over realize.

Implementations

impl RemoteTransport

pub fn wasm() -> Self

A wasm transport targeting an in-browser runtime.

pub fn local_server(endpoint: impl Into<String>) -> Self

A local-server transport (HTTP bootstrap + WebSocket live).

pub fn remote_server(endpoint: impl Into<String>) -> Self

A remote-server transport (HTTP bootstrap + WebSocket live).

pub fn endpoint(&self) -> &str

The configured endpoint.

pub fn connect(&mut self)

Mark the remote channel connected.

pub fn disconnect(&mut self)

Mark the remote channel disconnected.

pub fn begin_reconnect(&mut self)

Mark the remote channel reconnecting.

pub fn stream_control_frame( &self, cx: &mut Cx, codec: Symbol, control: &StreamControl, ) -> Result<ServerFrame>

Encode a stream-fabric control frame for server-backed transports.

Trait Implementations

impl Transport for RemoteTransport

fn kind(&self) -> TransportKind

Which kind of runtime this transport connects to.

fn status(&self) -> SessionStatus

The current connection status.

fn read(&self, _resource: &Symbol) -> Result<Expr>

Read the current value of a resource.

fn realize(&mut self, _resource: &Symbol, _operation: &Expr) -> Result<Expr>

Realize a checked operation against a resource, returning the new value (the realize_final surface). Implementations also record a ChangeEvent for the resource.

fn drain_events(&mut self) -> Vec<ChangeEvent>

Drain the pending change events (the realize_events surface).

fn stream_subscribe( &mut self, stream_id: &Symbol, ) -> Result<StreamInspectorRecord>

Subscribe to a stream and return browser-visible inspector data.

fn stream_read( &mut self, stream_id: &Symbol, _limit: usize, ) -> Result<Vec<StreamItem>>

Read at most limit packets from a stream.

fn stream_push( &mut self, stream_id: &Symbol, _envelope: StreamEnvelope, ) -> Result<PushResult>

Push one stream envelope.

fn stream_cancel(&mut self, stream_id: &Symbol) -> Result<()>

Cancel a stream.

fn stream_stats(&self, stream_id: &Symbol) -> Result<StreamStats>

Return current stream stats.

fn stream_inspector(&self, stream_id: &Symbol) -> Result<StreamInspectorRecord>

Return browser-visible inspector data without changing stream state.