Struct portus::ipc::chan::Socket

pub struct Socket<T> { /* private fields */ }

Implementations

impl<T> Socket<T>

pub fn new(to_ccp: Sender<Vec<u8>>, from_ccp: Receiver<Vec<u8>>) -> Self

Trait Implementations

impl Ipc for Socket<Blocking>

type Addr = ()

fn name() -> String

Returns the name of this IPC mechanism (e.g. “netlink” for Linux netlink sockets)

fn send(&self, msg: &[u8], _to: &Self::Addr) -> Result<()>

Blocking send

fn recv(&self, msg: &mut [u8]) -> Result<(usize, Self::Addr)>

Blocking listen.

fn close(&mut self) -> Result<()>

Close the underlying sockets

impl Ipc for Socket<Nonblocking>

type Addr = ()

fn name() -> String

Returns the name of this IPC mechanism (e.g. “netlink” for Linux netlink sockets)

fn send(&self, msg: &[u8], _to: &Self::Addr) -> Result<()>

Blocking send

fn recv(&self, msg: &mut [u8]) -> Result<(usize, Self::Addr)>

Blocking listen.

fn close(&mut self) -> Result<()>

Close the underlying sockets