Struct Sub0

pub struct Sub0 { /* private fields */ }

Subscribe half of publisher/subscriber pattern. See nng_sub.

Implementations

impl Sub0

pub fn open() -> Result<Self>

Create a sub socket. See nng_sub_open.

Trait Implementations

impl AsyncSocket for Sub0

type ContextType = SubscribeAsyncHandle

The type of aynchronous context produced

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

Turns the Socket into an asynchronous context

impl AsyncStream for Sub0

type ContextType = SubscribeAsyncStream

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 Sub0

fn clone(&self) -> Sub0

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Sub0

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

Formats the value using the given formatter.

impl Dial for Sub0

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 Sub0

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 Sub0

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 Sub0

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 Sub0

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 Sub0

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 Sub0

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.

impl Subscribe for Sub0

fn subscribe(&self, topic: &[u8]) -> Result<()>

Subscribe to a topic.

fn unsubscribe(&self, topic: &[u8]) -> Result<()>

Unsubscribe from a topic.

fn subscribe_str(&self, topic: &str) -> Result<()>

Subscribe to a topic.

fn unsubscribe_str(&self, topic: &str) -> Result<()>

Unsubscribe from a topic.