Struct mrsc::Server
[−]
[src]
pub struct Server<T, R> { /* fields omitted */ }
The server that receives requests and creates channels
Methods
impl<T, R> Server<T, R>
[src]
fn new() -> Server<T, R>
[src]
Create a new server.
Examples
use mrsc; let server: mrsc::Server<u32, String> = mrsc::Server::new();
fn pop(&self) -> Channel<T, R>
[src]
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>
[src]
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>
[src]
fn recv_timeout(
&self,
timeout: Duration
) -> Result<Request<T, R>, RecvTimeoutError>
[src]
&self,
timeout: Duration
) -> Result<Request<T, R>, RecvTimeoutError>