Struct StreamProbeEndpoint 

pub struct StreamProbeEndpoint;

In-memory endpoint that echoes sent values while preserving stream protocol semantics.

Trait Implementations

impl Clone for StreamProbeEndpoint

fn clone(&self) -> StreamProbeEndpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamProbeEndpoint

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

Formats the value using the given formatter.

impl Default for StreamProbeEndpoint

fn default() -> StreamProbeEndpoint

Returns the “default value” for a type.

impl NativeStreamEndpoint for StreamProbeEndpoint

fn capability_id(&self) -> &'static str

Stable Capability series identity.

fn descriptor_version(&self) -> &'static str

Exact Descriptor version implemented by this endpoint.

fn operations(&self) -> &'static [&'static str]

Exact stable stream Operation names implemented by this endpoint.

fn open( &self, operation: &str, request: Box<dyn Any>, context: InvocationContext, ) -> LocalBoxFuture<'static, Result<Result<Box<dyn NativeStreamSession>, Box<dyn Any>>, RuntimeFailure>>

Opens one stream without serializing its typed Rust payload.