Struct Session 

pub struct Session<'d> { /* private fields */ }

Implementations

impl<'d> Session<'d>

pub fn new(port: &'d Port<'d>) -> Self

Trait Implementations

impl<'d> Session<'d> for Session<'d>

type Codec = Codec

type ConnState = ConnState

type Send = Lease<'d>

fn connect(&mut self, ctx: &mut Ctx<'_, 'd, Self>)

fn response(&mut self, head: Head, ctx: &mut Ctx<'_, 'd, Self>)

fn disconnect(&mut self, ctx: &mut Ctx<'_, 'd, Self>)

fn pre_park(&mut self)

fn idle(&self) -> Idle

fn codec(&self) -> &Self::Codec

fn activate(&self, token: Token, ready: ReadyKey<'d>)

fn drain_requests( &self, token: Token, push: impl FnMut(Self::Send) -> Result<(), Self::Send>, ) -> Requests

fn flush_trailer(&mut self, ctx: &mut Ctx<'_, 'd, Self>)

fn sent(&self, token: Token, sent: usize)

fn defer_close(&self, token: Token, state: &Self::ConnState) -> bool

fn is_drained(&self, token: Token, state: &Self::ConnState) -> bool

fn inbound_idle_timeout(&self) -> Option<Duration>

Inbound-idle liveness bound (see ConnApp::inbound_idle_timeout). A protocol sets this to just over its keepalive cadence — e.g. AMQP returns 2 × the negotiated heartbeat once the handshake fixes the interval — so the connector force-reconnects a silently vanished peer. None disables.