Struct Server 

pub struct Server { /* private fields */ }

The standard, protocol-agnostic ChatServer implementation.

Construct one with Server::new, attach any number of listeners with Server::add_listener, then call ChatServer::run:

use chat_system::server::Server;
use chat_system::servers::IrcListener;
use chat_system::ChatServer;

let mut server = Server::new("my-server")
    .add_listener(IrcListener::new("0.0.0.0:6667"))
    .add_listener(IrcListener::new("0.0.0.0:6697"));

server.run(|msg| async move {
    println!("{}: {}", msg.sender, msg.content);
    Ok(Some(format!("echo: {}", msg.content)))
}).await?;

With the tls feature enabled, you can mix plaintext and TLS listeners:

use chat_system::servers::{IrcListener, TlsIrcListener};

let server = Server::new("my-server")
    .add_listener(IrcListener::new("0.0.0.0:6667"))
    .add_listener(TlsIrcListener::new("0.0.0.0:6697", tls_config));

Implementations

impl Server

pub fn new(name: impl Into<String>) -> Self

Create a new empty server with the given name.

pub fn add_listener(self, listener: impl ChatListener + 'static) -> Self

Attach a listener. The listener may speak any protocol.

Listeners must be added before calling ChatServer::run.

pub fn add_boxed_listener(self, listener: Box<dyn ChatListener>) -> Self

Attach an already-boxed listener.

This is useful when you already have a Box<dyn ChatListener>, for example from a ListenerConfig::build call. Listeners must be added before calling ChatServer::run.

Trait Implementations

impl ChatServer for Server

fn name(&self) -> &str

Human-readable name of this server.

fn listeners(&self) -> Vec<&dyn ChatListener>

Snapshot of all currently attached listeners (for introspection).

fn run<'life0, 'async_trait, F, Fut>( &'life0 mut self, handler: F, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where F: Fn(Message) -> Fut + Send + Sync + 'static + 'async_trait, Fut: Future<Output = Result<Option<String>>> + Send + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Start all listeners and run the server event loop.

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

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

Shut down all listeners, causing ChatServer::run to return.