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 local_server_address( endpoint: impl Into<String>, address: ServerAddress, ) -> Self

A local-server transport targeting an explicit server address.

pub fn remote_server_address( endpoint: impl Into<String>, address: ServerAddress, ) -> Self

A remote-server transport targeting an explicit server address.

pub fn endpoint(&self) -> &str

The configured endpoint.

pub fn address(&self) -> &ServerAddress

The server address this transport connects to.

pub fn with_offered_codecs(self, offered_codecs: Vec<Symbol>) -> Self

Override the codec offer set used during negotiation.

pub fn with_max_in_flight(self, max_in_flight: usize) -> Self

Override the maximum number of correlated requests allowed in flight.

pub fn with_timeout(self, timeout: Duration) -> Self

Override the request timeout used for server answers.

pub fn connect(&mut self, cx: &mut Cx) -> Result<()>

Request a remote connection and negotiate the server codec.

pub fn disconnect(&mut self)

Mark the remote channel disconnected.

pub fn begin_reconnect(&mut self)

Mark the remote channel reconnecting.

pub fn close(&mut self, cx: &mut Cx) -> Result<()>

Close the remote channel deliberately.

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(&mut self, cx: &mut Cx, resource: &Symbol) -> Result<Expr>

Read the current value of a resource.

fn realize_operation( &mut self, cx: &mut Cx, resource: &Symbol, operation: &Operation, ) -> 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 commit_operation( &mut self, cx: &mut Cx, resource: &Symbol, operation: &Operation, expected_current: Option<&Expr>, ) -> Result<Expr>

Commit an operation, optionally requiring the resource to still match expected_current on the server side.

fn drain_events(&mut self, cx: &mut Cx) -> Result<Vec<ChangeEvent>>

Drain the pending change events (the realize_events surface).

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

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

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

Read at most limit packets from a stream.

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

Push one stream envelope.

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

Cancel a stream.

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

Return current stream stats.

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

Return browser-visible inspector data without changing stream state.

fn realize( &mut self, cx: &mut Cx, resource: &Symbol, operation: &Expr, ) -> Result<Expr>

Realize a checked operation expression against a resource.