Struct EmbeddedChannelHandle 

pub struct EmbeddedChannelHandle { /* private fields */ }

Channel handle that publishes through direct in-process references.

Implementations

impl EmbeddedChannelHandle

pub fn new(config: &EmbeddedConfig) -> Self

Creates an embedded channel handle from direct in-process configuration.

pub fn channel_name(&self) -> &str

Returns the application-visible channel name.

Trait Implementations

impl ChannelHandle for EmbeddedChannelHandle

type Subscription<M> = SdkSubscription<M> where M: DeserializeOwned

Stream returned by subscribe for message type M.

type ReplyFuture<'a, Resp> = ReadyResult<Resp> where Self: 'a, Resp: DeserializeOwned + 'a

Future returned by request_reply for reply type Resp.

fn publish<M>(&self, message: M) -> Result<PressureResponse, SdkError>

where M: Serialize + SchemaValidate,

Publishes a typed message to the channel.

fn subscribe<M>(&self) -> Self::Subscription<M>

where M: DeserializeOwned,

Subscribes to typed channel messages.

fn request_reply<Req, Resp>(&self, request: Req) -> ReadyResult<Resp>

where Req: Serialize + SchemaValidate, Resp: DeserializeOwned,

Sends a typed request and resolves with a typed reply.

impl Clone for EmbeddedChannelHandle

fn clone(&self) -> EmbeddedChannelHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EmbeddedChannelHandle

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

Formats the value using the given formatter.