Struct ConnectionHandlerSelect 

pub struct ConnectionHandlerSelect<THandler1, THandler2> { /* private fields */ }

Implementations

impl<THandler1, THandler2> ConnectionHandlerSelect<THandler1, THandler2>

pub fn select(first: THandler1, second: THandler2) -> Self

Trait Implementations

impl<THandler1: Clone, THandler2: Clone> Clone for ConnectionHandlerSelect<THandler1, THandler2>

fn clone(&self) -> ConnectionHandlerSelect<THandler1, THandler2>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<THandler1, THandler2> ConnectionHandler for ConnectionHandlerSelect<THandler1, THandler2>

where THandler1: ConnectionHandler, THandler2: ConnectionHandler,

type Action = Either<<THandler1 as ConnectionHandler>::Action, <THandler2 as ConnectionHandler>::Action>

type Event = Either<<THandler1 as ConnectionHandler>::Event, <THandler2 as ConnectionHandler>::Event>

fn handle_action(&mut self, action: Self::Action)

fn connection_keep_alive(&self) -> bool

fn poll_close(&mut self, cx: &mut Context<'_>) -> Poll<Option<Self::Event>>

fn poll( &mut self, cx: &mut Context<'_>, ) -> Poll<ConnectionHandlerEvent<Self::Event>>

fn select<H>(self, other: H) -> ConnectionHandlerSelect<Self, H>

where H: ConnectionHandler, Self: Sized,

fn map_event<O, F>(self, map: F) -> MapEvent<Self, F>

where Self: Sized, O: Debug + Send + 'static, F: FnMut(Self::Event) -> O + Send + 'static,

fn map_action<O, F>(self, map: F) -> MapAction<Self, O, F>

where Self: Sized, O: Debug + Send + 'static, F: FnMut(O) -> Option<Self::Action> + Send + 'static,

impl<THandler1: Debug, THandler2: Debug> Debug for ConnectionHandlerSelect<THandler1, THandler2>

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

Formats the value using the given formatter.

impl<THandler1, THandler2> InboundStreamHandler for ConnectionHandlerSelect<THandler1, THandler2>

where THandler1: InboundStreamHandler, THandler2: InboundStreamHandler,

type InboundUpgrade = SelectUpgrade<SendWrapper<<THandler1 as InboundStreamHandler>::InboundUpgrade>, SendWrapper<<THandler2 as InboundStreamHandler>::InboundUpgrade>>

type InboundUserData = (<THandler1 as InboundStreamHandler>::InboundUserData, <THandler2 as InboundStreamHandler>::InboundUserData)

fn listen_protocol( &self, ) -> SubstreamProtocol<Self::InboundUpgrade, Self::InboundUserData>

fn on_fully_negotiated( &mut self, user_data: Self::InboundUserData, protocol: <Self::InboundUpgrade as InboundUpgradeSend>::Output, )

fn on_upgrade_error( &mut self, user_data: Self::InboundUserData, error: <Self::InboundUpgrade as InboundUpgradeSend>::Error, )

impl<THandler1, THandler2> OutboundStreamHandler for ConnectionHandlerSelect<THandler1, THandler2>

where THandler1: OutboundStreamHandler, THandler2: OutboundStreamHandler,

type OutboundUpgrade = Either<SendWrapper<<THandler1 as OutboundStreamHandler>::OutboundUpgrade>, SendWrapper<<THandler2 as OutboundStreamHandler>::OutboundUpgrade>>

type OutboundUserData = Either<<THandler1 as OutboundStreamHandler>::OutboundUserData, <THandler2 as OutboundStreamHandler>::OutboundUserData>

fn on_fully_negotiated( &mut self, user_data: Self::OutboundUserData, protocol: <Self::OutboundUpgrade as OutboundUpgradeSend>::Output, )

fn on_upgrade_error( &mut self, user_data: Self::OutboundUserData, error: StreamUpgradeError<<Self::OutboundUpgrade as OutboundUpgradeSend>::Error>, )

fn poll_outbound_request( &mut self, cx: &mut Context<'_>, ) -> Poll<SubstreamProtocol<Self::OutboundUpgrade, Self::OutboundUserData>>