Struct EventProbeEndpoint 

pub struct EventProbeEndpoint { /* private fields */ }

In-memory Event endpoint used by the conformance Adapter.

Implementations

impl EventProbeEndpoint

pub fn new(recorder: EventProbeRecorder) -> Self

pub fn set_available(&self, available: bool)

Trait Implementations

impl Clone for EventProbeEndpoint

fn clone(&self) -> EventProbeEndpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventProbeEndpoint

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

Formats the value using the given formatter.

impl NativeEventEndpoint for EventProbeEndpoint

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 Event Operation names implemented by this endpoint.

fn publish( &self, operation: &str, event: Box<dyn Any>, _context: InvocationContext, ) -> LocalBoxFuture<'static, Result<(), RuntimeFailure>>

Publishes one value after the endpoint has admitted it.

fn owns_event_admission(&self) -> bool

Returns whether the Adapter owns the subscriber’s admission queue.