Struct runng::protocol::pull0::Pull0

pub struct Pull0 { /* fields omitted */ }

Pull half of push/pull ("pipeline") pattern. See nng_pull.

Methods

impl Pull0

pub fn open() -> Result<Self>

Create a pull socket. See nng_pull_open.

Trait Implementations

impl AsyncSocket for Pull0

type ContextType = PullAsyncHandle

The type of aynchronous context produced

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

Turns the Socket into an asynchronous context

impl AsyncStream for Pull0

type ContextType = PullAsyncStream

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 Pull0

fn clone(&self) -> Pull0

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Pull0

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

Formats the value using the given formatter.

impl Dial for Pull0

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 GetOpts for Pull0

fn get_bool(&self, option: NngOption) -> Result<bool>

Get bool option. See #get_bool

fn get_int(&self, option: NngOption) -> Result<i32>

Get i32 option. See #get_int

fn get_ms(&self, option: NngOption) -> Result<i32>

Get nng_duration option. See #get_ms

fn get_size(&self, option: NngOption) -> Result<usize>

Get usize option. See #get_size

fn get_uint64(&self, option: NngOption) -> Result<u64>

Get u64 option. See #get_uint64

fn get_string(&self, option: NngOption) -> Result<NngString>

Get NngString option. See #get_string

impl GetSocket for Pull0

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 Pull0

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 Pull0

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 SetOpts for Pull0

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 Pull0

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.