Enum SdkChannelHandle 

pub enum SdkChannelHandle {
    Embedded(EmbeddedChannelHandle),
    Remote(RemoteChannelHandle),
}

Runtime-selected channel handle that keeps deployment differences behind configuration.

Variants

Embedded(EmbeddedChannelHandle)

Embedded direct in-process handle.

Remote(RemoteChannelHandle)

Remote protocol-backed handle.

Implementations

impl SdkChannelHandle

pub fn new(config: &SdkConfig) -> Result<Self, SdkError>

Creates a channel handle selected by SDK configuration.

Errors

Returns SdkError if the selected handle cannot be initialized.

Trait Implementations

impl ChannelHandle for SdkChannelHandle

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

where M: DeserializeOwned,

BOTH ARMS REFUSE. Typed subscription delivery is not implemented in either deployment mode, so whichever mode configuration selected, the returned stream yields exactly one Err(SdkError::Unwired) and then ends.

The remote arm’s refusal names SubscriptionStream::open as the surface that works. The embedded arm’s names the same remote surface, because embedded mode has no in-process delivery path to offer instead. That arm used to return a locally empty stream — described here as “what embedded mode has always meant”, which was true of the implementation and misleading to a caller: an empty stream is indistinguishable from a live subscription on a quiet channel.

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

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SdkChannelHandle

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

Formats the value using the given formatter.