Struct mrsc::Server

pub struct Server<T, R> { /* fields omitted */ }

The server that receives requests and creates channels

Methods

impl<T, R> Server<T, R>

fn new() -> Server<T, R>

Create a new server.

Examples

use mrsc;

let server: mrsc::Server<u32, String> = mrsc::Server::new();

fn pop(&self) -> Channel<T, R>

Request a new channel for a worker thread.

A channel can safely be cloned without calling pop() for every worker.

Examples

use mrsc;

let server: mrsc::Server<u32, String> = mrsc::Server::new();
let channel = server.pop();

fn recv(&self) -> Result<Request<T, R>, RecvError>

Receive a request from a worker thread.

Examples

use mrsc;

let server: mrsc::Server<u32, String> = mrsc::Server::new();

let channel = server.pop();
// send request
let response = channel.req(123).unwrap();

// receive request
let req = server.recv().unwrap();

fn try_recv(&self) -> Result<Request<T, R>, TryRecvError>

fn recv_timeout(
    &self,
    timeout: Duration
) -> Result<Request<T, R>, RecvTimeoutError>

Trait Implementations

impl<T: Debug, R: Debug> Debug for Server<T, R>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.