Struct internet2::transport::zeromq::Connection

pub struct Connection { /* private fields */ }

Implementations

impl Connection

pub fn connect(
api_type: ZmqSocketType,
remote: &ServiceAddr,
local: Option<&ServiceAddr>,
identity: Option<impl AsRef<[u8]>>,
context: &Context
) -> Result<Self, Error>

pub fn with_socket(api_type: ZmqSocketType, socket: Socket) -> Self

pub fn set_identity(
&mut self,
identity: &impl AsRef<[u8]>,
context: &Context
) -> Result<(), Error>

Trait Implementations

impl Bipolar for Connection

type Left = WrappedSocket

First separable type (like reader)

type Right = WrappedSocket

Second separable type (like writer)

fn join(input: Self::Left, output: Self::Right) -> Self

Reconstruct the type from the halves

fn split(self) -> (Self::Left, Self::Right)

Split the type into two

impl DuplexConnection for Connection

fn as_receiver(&mut self) -> &mut dyn RecvFrame

fn as_sender(&mut self) -> &mut dyn SendFrame

fn split(self) -> (Box<dyn RecvFrame + Send>, Box<dyn SendFrame + Send>)