Struct dendrite_auth::dendrite::axon_utils::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>( &self, label: S, task: &'static T ) -> Result<(), Error>

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

👎Deprecated

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

where S: Into<String>, T: IntoPinFuture,

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 'life0: 'async_trait, AxonServerHandle: 'async_trait,

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

where 'life0: 'async_trait, AxonServerHandle: 'async_trait,

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

where 'life0: 'async_trait, 'life1: 'async_trait, AxonServerHandle: '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 copy 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>, Error>> + Send + 'async_trait>>

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

👎Deprecated since 0.8.0: Use struct SubmitCommand instead

impl Debug for AxonServerHandle

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

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>, Error>> + Send + 'async_trait>>

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