Struct Context

pub struct Context { /* private fields */ }

Handle for a 0MQ context, used to create sockets.

It is thread safe, and can be safely cloned and shared. Each clone references the same underlying C context. Internally, an Arc is used to implement this in a threadsafe way.

Also note that this binding deviates from the C API in that each socket created from a context initially owns a clone of that context. This reference is kept to avoid a potential deadlock situation that would otherwise occur:

Destroying the underlying C context is an operation which blocks waiting for all sockets created from it to be closed first. If one of the sockets belongs to thread issuing the destroy operation, you have established a deadlock.

You can still deadlock yourself (or intentionally close sockets in other threads, see zmq_ctx_destroy(3)) by explicitly calling Context::destroy.

Implementations

impl Context

pub fn new() -> Context

Create a new reference-counted context handle.

pub fn get_io_threads(&self) -> Result<i32>

Get the size of the ØMQ thread pool to handle I/O operations.

pub fn set_io_threads(&self, value: i32) -> Result<()>

Set the size of the ØMQ thread pool to handle I/O operations.

pub fn socket(&self, socket_type: SocketType) -> Result<Socket>

Create a new socket.

Note that the returned socket keeps a an Arc reference to the context it was created from, and will keep that context from being dropped while being live.

pub fn destroy(&mut self) -> Result<()>

Try to destroy the context. This is different than the destructor; the destructor will loop when zmq_ctx_term returns EINTR.

Trait Implementations

impl Clone for Context

fn clone(&self) -> Context

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for Context

fn default() -> Self

Returns the “default value” for a type.