Enum EitherOutput 

pub enum EitherOutput<A, B> {
    A(A),
    B(B),
}

Variants

A(A)

B(B)

Trait Implementations

impl<A, B> AsyncRead for EitherOutput<A, B>

where A: AsyncRead, B: AsyncRead,

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>], ) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.

impl<A, B> AsyncWrite for EitherOutput<A, B>

where A: AsyncWrite, B: AsyncWrite,

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the object.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from bufs into the object using vectored IO operations.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempt to flush the object, ensuring that any buffered data reach their destination.

fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempt to close the object.

impl<A: Clone, B: Clone> Clone for EitherOutput<A, B>

fn clone(&self) -> EitherOutput<A, B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A, B> ConnectionInfo for EitherOutput<A, B>

where A: ConnectionInfo, B: ConnectionInfo,

fn local_multiaddr(&self) -> Multiaddr

fn remote_multiaddr(&self) -> Multiaddr

impl<A: Debug, B: Debug> Debug for EitherOutput<A, B>

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

Formats the value using the given formatter.

impl<A, B> SecureInfo for EitherOutput<A, B>

where A: SecureInfo, B: SecureInfo,

fn local_peer(&self) -> PeerId

fn remote_peer(&self) -> PeerId

fn local_priv_key(&self) -> Keypair

fn remote_pub_key(&self) -> PublicKey

impl<A, B> StreamInfo for EitherOutput<A, B>

where A: StreamInfo, B: StreamInfo,

fn id(&self) -> usize

Returns the identity of the stream.

impl<A, B> StreamMuxer for EitherOutput<A, B>

where A: StreamMuxer + Send, B: StreamMuxer + Send,

fn open_stream<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<IReadWrite, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Opens a new outgoing substream.

fn accept_stream<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<IReadWrite, TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Accepts a new incoming substream.

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Closes the stream muxer, the runtime of stream muxer will then exit.

fn task(&mut self) -> Option<BoxFuture<'static, ()>>

Returns a Future which represents the main loop of the stream muxer.

fn box_clone(&self) -> IStreamMuxer

Returns the cloned Trait object.

impl<A: Copy, B: Copy> Copy for EitherOutput<A, B>

impl<A, B> StreamMuxerEx for EitherOutput<A, B>

where A: StreamMuxer + ConnectionInfo + SecureInfo + Debug, B: StreamMuxer + ConnectionInfo + SecureInfo + Debug,

impl<'pin, A, B> Unpin for EitherOutput<A, B>

where __EitherOutput<'pin, A, B>: Unpin,

impl<A, B> UnsafeUnpin for EitherOutput<A, B>