Struct runng::asyncio::stream::NngStream

pub struct NngStream { /* fields omitted */ }

Byte stream corresponding to TCP, UNIX domain socket, named pipe, etc. connection. Wraps nng_stream

Methods

impl NngStream

pub fn send(
    &mut self,
    queue: &mut impl AioWorkQueue,
    iov: IoVec
) -> Receiver<Result<usize>>

Send to byte stream.

pub fn recv(
    &mut self,
    queue: &mut impl AioWorkQueue,
    iov: IoVec
) -> Receiver<Result<IoVec>>

Receive from byte stream.

pub fn close(&self)

Close the stream.

Trait Implementations

impl Debug for NngStream

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

Formats the value using the given formatter.

impl Drop for NngStream

fn drop(&mut self)

Close stream and release resources.

impl GetOpts for NngStream

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

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>