Struct FabricTransport 

pub struct FabricTransport { /* private fields */ }

A transport that commits operations by delegating to an EvalFabric.

Reads return locally stored values and change events accumulate locally; Transport::realize is forwarded to the fabric, whose reply value becomes the new value of the realized resource.

Implementations

impl FabricTransport

pub fn new(fabric: EvalFabricRef) -> Self

A connected, empty transport over fabric (with its own kernel context).

pub fn with(self, resource: Symbol, value: Expr) -> Self

Seed a resource value (builder form).

pub fn set(&mut self, resource: Symbol, value: Expr)

Seed or replace a resource value.

Trait Implementations

impl Transport for FabricTransport

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.