Struct runng::protocol::pair1::Pair1

pub struct Pair1 { /* fields omitted */ }

Half of pair pattern. See nng_pair.

Methods

impl Pair1

pub fn open() -> Result<Self>

Create a new pair socket. See nng_pair_open.

Trait Implementations

impl AsyncSocket for Pair1

type ContextType = PairAsyncHandle

The type of aynchronous context produced

fn create_async(&self) -> Result<Self::ContextType>

Turns the Socket into an asynchronous context

impl AsyncStream for Pair1

type ContextType = PairStreamHandle

The type of aynchronous context produced

fn create_async_stream(&self, buffer: usize) -> Result<Self::ContextType>

Turns the Socket into an asynchronous context

impl Clone for Pair1

fn clone(&self) -> Pair1

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Pair1

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

Formats the value using the given formatter.

impl Dial for Pair1

fn dial(&mut self, url: &str) -> Result<&mut Self>

Dial socket specified by URL. See nng_dial

fn dial_flags(&mut self, url: &str, flags: SocketFlags) -> Result<&mut Self>

Dial socket specified by URL. See nng_dial

fn dialer_create(&self, url: &str) -> Result<NngDialer>

impl GetSocket for Pair1

fn socket(&self) -> &NngSocket

Obtain underlying NngSocket.

fn socket_mut(&mut self) -> &mut NngSocket

unsafe fn nng_socket(&self) -> nng_socket

Obtain underlying nng_socket.

impl Listen for Pair1

fn listen(&mut self, url: &str) -> Result<&mut Self>

Listen for connections to specified URL. See nng_listen.

fn listen_flags(&mut self, url: &str, flags: SocketFlags) -> Result<&mut Self>

Listen for connections to specified URL. See nng_listen.

fn listener_create(&self, url: &str) -> Result<NngListener>

impl RecvSocket for Pair1

fn recv<'a>(&self, buffer: &'a mut [u8]) -> Result<&'a [u8]>

Receive data. See nng_recv. Lifetime of return value is same as input buffer.

fn recv_flags<'a>(&self, buffer: &'a mut [u8], flags: Flags) -> Result<&'a [u8]>

Receive data with Flags. Lifetime of return value is same as input buffer.

fn recv_zerocopy(&self) -> Result<Alloc>

Receive data in "zero-copy" mode. See NNG_FLAG_ALLOC.

fn recv_zerocopy_flags(&self, flags: Flags) -> Result<Alloc>

Receive data in "zero-copy" mode with Flags.

fn recvmsg(&self) -> Result<NngMsg>

Receive a NngMsg: recvmsg_flags(..., 0)

fn recvmsg_flags(&self, flags: Flags) -> Result<NngMsg>

Receive a NngMsg with Flags. See nng_recvmsg.

impl SendSocket for Pair1

fn send(&self, data: &[u8]) -> Result<()>

Send data. See nng_send.

fn send_flags(&self, data: &[u8], flags: Flags) -> Result<()>

Send data with Flags. See nng_send.

fn send_zerocopy(&self, data: Alloc) -> Result<(), SendError<Alloc>>

Sends data in "zero-copy" mode. See NNG_FLAG_ALLOC.

fn send_zerocopy_flags(
    &self,
    data: Alloc,
    flags: Flags
) -> Result<(), SendError<Alloc>>

Send data in "zero-copy" mode with Flags. See NNG_FLAG_ALLOC.

fn sendmsg(&self, msg: NngMsg) -> Result<()>

Send a NngMsg. See nng_sendmsg.

fn sendmsg_flags(
    &self,
    msg: NngMsg,
    flags: Flags
) -> Result<(), SendError<NngMsg>>

Send a NngMsg with Flags. See nng_sendmsg.

impl SetOpts for Pair1

fn set_bool(&mut self, option: NngOption, value: bool) -> Result<&mut Self>

Set bool NngOption. See #set_bool

fn set_int(&mut self, option: NngOption, value: i32) -> Result<&mut Self>

See #set_int

fn set_ms(&mut self, option: NngOption, value: i32) -> Result<&mut Self>

See #set_ms

fn set_size(&mut self, option: NngOption, value: usize) -> Result<&mut Self>

See #set_size

fn set_uint64(&mut self, option: NngOption, value: u64) -> Result<&mut Self>

See #set_uint64

fn set_string(&mut self, option: NngOption, value: &str) -> Result<&mut Self>

See #set_string

fn set_duration(
    &mut self,
    option: NngOption,
    value: Duration
) -> Result<&mut Self>

impl Socket for Pair1

fn with<T>(self, setup: T) -> Result<Self> where
    T: FnOnce(&mut Self) -> Result<&mut Self>, 

Helper to chain constructors with methods that return &Self.