Struct AxonServerHandle

pub struct AxonServerHandle {
    pub display_name: String,
    pub client_id: String,
    pub conn: Channel,
    pub notify: Sender<Uuid>,
    /* private fields */
}

A handle for AxonServer.

Fields

display_name: String

client_id: String

conn: Channel

notify: Sender<Uuid>

Implementations

impl AxonServerHandle

pub fn spawn_ref<T, F, S: Into<String>>( &self, label: S, task: &'static T, ) -> Result<()>

where T: Fn(AxonServerHandle, WorkerControl) -> F, F: Future<Output = ()> + Send + 'static,

👎Deprecated

pub fn spawn<S: Into<String>, T: IntoPinFuture>( &self, label: S, task: T, ) -> Result<Uuid>

Trait Implementations

impl AxonServerHandleAsyncTrait for AxonServerHandle

fn dispatch<'life0, 'async_trait>( &'life0 self, request: Command, ) -> Pin<Box<dyn Future<Output = Result<Response<CommandResponse>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn join_workers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn join_workers_with_signal<'life0, 'life1, 'async_trait>( &'life0 self, terminate: &'life1 mut Option<Signal>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl AxonServerHandleTrait for AxonServerHandle

fn client_id(&self) -> &str

fn display_name(&self) -> &str

impl Clone for AxonServerHandle

fn clone(&self) -> AxonServerHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CommandSink for AxonServerHandle

fn send_command<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, command_type: &'life1 str, command: &'life2 (dyn VecU8Message + Sync), ) -> Pin<Box<dyn Future<Output = Result<Option<SerializedObject>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

👎Deprecated since 0.8.0: Use struct SubmitCommand instead

impl Debug for AxonServerHandle

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

Formats the value using the given formatter.

impl QuerySink for AxonServerHandle

fn send_query<'a, 'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query_type: &'life1 str, query: &'life2 (dyn VecU8Message + Sync), ) -> Pin<Box<dyn Future<Output = Result<Vec<SerializedObject>>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,