Struct DummyContext 

pub struct DummyContext { /* private fields */ }

Minimal Context implementation for tests.

Implementations

impl DummyContext

pub fn new(self_id: ActrId) -> Self

Create a new dummy context with random request id.

pub fn with_caller_id(self, caller_id: Option<ActrId>) -> Self

Set caller id (useful for tests that verify propagation).

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

Override request id for deterministic testing.

Trait Implementations

impl Clone for DummyContext

fn clone(&self) -> DummyContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Context for DummyContext

fn self_id(&self) -> &ActrId

Get the current Actor’s ID

fn caller_id(&self) -> Option<&ActrId>

Get the caller’s Actor ID

fn request_id(&self) -> &str

Get the unique request ID

fn call<'life0, 'life1, 'async_trait, R>( &'life0 self, _target: &'life1 Dest, _request: R, ) -> Pin<Box<dyn Future<Output = ActorResult<R::Response>> + Send + 'async_trait>>

where R: 'async_trait + RpcRequest, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a type-safe RPC request and wait for response

fn tell<'life0, 'life1, 'async_trait, R>( &'life0 self, _target: &'life1 Dest, _message: R, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where R: 'async_trait + RpcRequest, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a type-safe one-way message (no response expected)

fn register_stream<'life0, 'async_trait, F>( &'life0 self, _stream_id: String, _callback: F, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where F: Fn(DataStream, ActrId) -> BoxFuture<'static, ActorResult<()>> + Send + Sync + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Register a DataStream callback for a specific stream

fn unregister_stream<'life0, 'life1, 'async_trait>( &'life0 self, _stream_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Unregister a DataStream callback

fn send_data_stream<'life0, 'life1, 'async_trait>( &'life0 self, _target: &'life1 Dest, _chunk: DataStream, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Send a DataStream to a destination

fn discover_route_candidate<'life0, 'life1, 'async_trait>( &'life0 self, _target_type: &'life1 ActrType, ) -> Pin<Box<dyn Future<Output = ActorResult<ActrId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Discover a remote Actor of the specified type via the signaling server.

fn call_raw<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _target: &'life1 ActrId, _route_key: &'life2 str, _payload: Bytes, ) -> Pin<Box<dyn Future<Output = ActorResult<Bytes>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Send a raw RPC request (untyped bytes) and wait for response

fn register_media_track<'life0, 'async_trait, F>( &'life0 self, _track_id: String, _callback: F, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where F: Fn(MediaSample, ActrId) -> BoxFuture<'static, ActorResult<()>> + Send + Sync + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Register a WebRTC native media track callback

fn unregister_media_track<'life0, 'life1, 'async_trait>( &'life0 self, _track_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Unregister a media track callback

fn send_media_sample<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _target: &'life1 Dest, _track_id: &'life2 str, _sample: MediaSample, ) -> Pin<Box<dyn Future<Output = ActorResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Send media samples via WebRTC native track

impl Debug for DummyContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.