Struct FixtureTransport 

pub struct FixtureTransport { /* private fields */ }

An in-memory transport for deterministic sessions and replay.

Implementations

impl FixtureTransport

pub fn new() -> Self

A connected, empty fixture.

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.

pub fn with_finite_stream( self, metadata: StreamMetadata, items: Vec<StreamItem>, ) -> Self

Seed a deterministic finite stream.

pub fn with_push_stream(self, metadata: StreamMetadata) -> Self

Seed a push stream.

pub fn set_finite_stream( &mut self, metadata: StreamMetadata, items: Vec<StreamItem>, )

Seed or replace a deterministic finite stream.

pub fn set_push_stream(&mut self, metadata: StreamMetadata)

Seed or replace a push stream.

pub fn mark_stream_refused( &mut self, stream_id: &Symbol, diagnostic: Symbol, ) -> Result<()>

Mark a stream as refused after a profile diagnostic.

pub fn disconnect(&mut self)

Simulate connection loss.

pub fn begin_reconnect(&mut self)

Simulate a reconnecting transport.

pub fn reconnect(&mut self)

Simulate a restored connection.

Trait Implementations

impl Default for FixtureTransport

fn default() -> Self

Returns the “default value” for a type.

impl Transport for FixtureTransport

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 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.

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.