Struct EmbeddedConversationHandle 

pub struct EmbeddedConversationHandle { /* private fields */ }

Conversation handle that sends through direct in-process references.

Implementations

impl EmbeddedConversationHandle

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

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

pub const fn conversation_id(&self) -> &ConversationId

Returns the application-visible conversation identifier.

Trait Implementations

impl Clone for EmbeddedConversationHandle

fn clone(&self) -> EmbeddedConversationHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConversationHandle for EmbeddedConversationHandle

type ReceiveFuture<'a, M> = ReadyResult<M> where Self: 'a, M: DeserializeOwned + 'a

Future returned by receive for message type M.

type LifecycleStream = EmptyLifecycleStream

Stream returned by lifecycle.

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

where M: Serialize,

Sends a typed message within this conversation.

fn receive<M>(&self) -> ReadyResult<M>

where M: DeserializeOwned,

Receives the next typed message from this conversation.

fn lifecycle(&self) -> Self::LifecycleStream

Observes lifecycle events for this conversation.

impl Debug for EmbeddedConversationHandle

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

Formats the value using the given formatter.