[][src]Struct nng::Context

pub struct Context { /* fields omitted */ }

A socket context.

The context allows for independent and concurrent use of stateful operations on a single socket. Using contexts is an excellent way to write simpler concurrent applications, while retaining the benefits of the protocol-specific advanced processing.

Note that not all protocols allow for the creation of contexts.

Examples

See the documentation of the Aio type for examples on how to use Socket Contexts.

Methods

impl Context[src]

pub fn new(socket: &Socket) -> Result<Context>[src]

Creates a new socket context.

pub fn send<M: Into<Message>>(
    &self,
    aio: &Aio,
    msg: M
) -> Result<(), (Message, Error)>
[src]

Send a message using the context asynchronously.

This function will return immediately. If there is already an I/O operation in progress, this function will return ErrorKind::TryAgain and return the message to the caller.

pub fn recv(&self, aio: &Aio) -> Result<()>[src]

Receive a message using the context asynchronously.

This function will return immediately. If there is already an I/O operation in progress that is not a receive operation, this function will return ErrorKind::TryAgain.

pub fn close(&self)[src]

Closes the context.

Messages that have been submitted for sending may be flushed or delivered, depending on the underlying transport and the linger option. Further attempts to use the context (with this or any other handle) will result in an error. Threads waiting for operations on the context when this call is executed may also return with an error.

Closing the owning socket also closes this context. Additionally, the context is closed once all handles have been dropped.

Trait Implementations

impl GetOpt<ResendTime> for Context[src]

impl GetOpt<SurveyTime> for Context[src]

impl SetOpt<ResendTime> for Context[src]

impl SetOpt<SurveyTime> for Context[src]

impl Clone for Context[src]

impl Eq for Context[src]

impl Ord for Context[src]

impl PartialEq<Context> for Context[src]

impl PartialOrd<Context> for Context[src]

impl Debug for Context[src]

impl Hash for Context[src]

Auto Trait Implementations

impl Send for Context

impl Sync for Context

impl Unpin for Context

impl UnwindSafe for Context

impl RefUnwindSafe for Context

Blanket Implementations

impl<T> Options for T where
    T: HasOpts, 
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> ToOwned for T where
    T: Clone
[src]

type Owned = T

The resulting type after obtaining ownership.

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = !

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> Any for T where
    T: 'static + ?Sized
[src]