Struct pushevent::server::Server

pub struct Server { /* fields omitted */ }

The main server struct that gets returned when a ws server is opened. It encapsulates a vector of thread join handles, which holds mainly our Websocket server thread and a thread which receives messages from our mpsc channel. It also holds our inner ServerRef which you probably don't need to touch.

Methods

impl Server

pub fn new(addr: &'static str) -> Self

Returns a server instance. As soon as this method is called, a websocket server is opened and a thread will start accepting events to be published.

Arguments

• addr - Static string slice which holds the address on which to open the websocket server

Example

use pushevent::server::Server;
let server = Server::new("127.0.0.1:3012");

pub fn get_tx(&self) -> Sender<Event>

Clones and returns a mpsc tx channel through which we can send events of Event type.

Example

use std::thread;

let server = Server::new("127.0.0.1:3012");

loop {
    let tx = server.get_tx();
    let _ = std::thread::spawn(move || {
        tx.send(...);
    });
}

pub fn join_threads(&mut self)

This method cleans up all of our threads and should be called on exit of your main application. It drains all threads from self.threads and tries to join them.

Example

use pushevent::server::Server;
let mut server = Server::new("127.0.0.1:3012");
server.join_threads();