Struct wicrs_server::server::Server

pub struct Server { /* fields omitted */ }

Server that handles socket clients and manages notifying them of new messages/changes as well as sending messages to be indexed by Tantivy.

Implementations

impl Server

pub async fn new(secret_key: SignedSecretKey) -> Result<Self>

Creates a new server with default options, also creates a MessageServer with the given commit_threshold (how many messages should be added to the search index before commiting to the index).

Trait Implementations

impl Actor for Server

#[must_use]

fn started<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Called when the actor is first started.

#[must_use]

fn stopped<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    ctx: &'life1 mut Context<Self>
) -> Pin<Box<dyn Future<Output = ()> + 'async_trait + Send, Global>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Called after an actor is stopped.

#[must_use]

fn start_default<'async_trait>(
) -> Pin<Box<dyn Future<Output = Result<Addr<Self>, Error>> + 'async_trait + Send, Global>> where
    Self: Default + 'async_trait, 

Construct and start a new actor, returning its address.

#[must_use]

fn start<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<Addr<Self>, Error>> + 'async_trait + Send, Global>> where
    Self: 'async_trait, 

Start a new actor, returning its address.

impl Handler<Connect> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    msg: Connect
) -> Pin<Box<dyn Future<Output = u128> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.

impl Handler<Disconnect> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    msg: Disconnect
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.

impl Handler<GetMessageServer> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    _msg: GetMessageServer
) -> Pin<Box<dyn Future<Output = Addr<MessageServer>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.

impl Handler<ServerNotification> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    msg: ServerNotification
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.

impl Handler<StartTyping> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    msg: StartTyping
) -> Pin<Box<dyn Future<Output = Result> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.

impl Handler<StopTyping> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    msg: StopTyping
) -> Pin<Box<dyn Future<Output = Result> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.

impl Handler<SubscribeChannel> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    msg: SubscribeChannel
) -> Pin<Box<dyn Future<Output = Result> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.

impl Handler<SubscribeHub> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    msg: SubscribeHub
) -> Pin<Box<dyn Future<Output = Result> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.

impl Handler<UnsubscribeChannel> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    msg: UnsubscribeChannel
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.

impl Handler<UnsubscribeHub> for Server

fn handle<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    _ctx: &'life1 mut Context<Self>,
    msg: UnsubscribeHub
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Method is called for every message received by this Actor.