Struct Rep0

pub struct Rep0 { /* private fields */ }

Reply half of request/reply pattern. See nng_rep.

Implementations

impl Rep0

pub fn open() -> Result<Self>

Create a new reply socket. See nng_rep_open.

Trait Implementations

impl AsyncSocket for Rep0

type ContextType = ReplyAsyncHandle

The type of aynchronous context produced

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

Turns the Socket into an asynchronous context

impl AsyncStream for Rep0

type ContextType = ReplyStreamHandle

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 Rep0

fn clone(&self) -> Rep0

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Rep0

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

Formats the value using the given formatter.

impl Dial for Rep0

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 Rep0

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 Rep0

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 Rep0

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 Rep0

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 Rep0

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 Rep0

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 Rep0

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.