[−][src]Struct nng::Context
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]
&self,
aio: &Aio,
msg: M
) -> Result<(), (Message, Error)>
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]
fn cmp(&self, other: &Context) -> Ordering
[src]
fn max(self, other: Self) -> Self
1.21.0[src]
fn min(self, other: Self) -> Self
1.21.0[src]
fn clamp(self, min: Self, max: Self) -> Self
[src]
impl PartialEq<Context> for Context
[src]
impl PartialOrd<Context> for Context
[src]
fn partial_cmp(&self, other: &Context) -> Option<Ordering>
[src]
#[must_use]
fn lt(&self, other: &Rhs) -> bool
1.0.0[src]
#[must_use]
fn le(&self, other: &Rhs) -> bool
1.0.0[src]
#[must_use]
fn gt(&self, other: &Rhs) -> bool
1.0.0[src]
#[must_use]
fn ge(&self, other: &Rhs) -> bool
1.0.0[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]
T: HasOpts,
fn get_opt<T: OptOps>(&self) -> Result<T::OptType> where
Self: GetOpt<T>,
[src]
Self: GetOpt<T>,
fn set_opt<T: OptOps>(&self, val: T::OptType) -> Result<()> where
Self: SetOpt<T>,
[src]
Self: SetOpt<T>,
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = !
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,