Struct ConnHandler 

pub struct ConnHandler;

Graceful stream shutdown handler

Trait Implementations

impl ConnHandler<BufReader<RecvStream>, SendStream> for ConnHandler

const DRAIN: bool = false

Whether to keep reading once all Incoming handles are dropped until the peer closes the stream, rather than aborting ingress and dropping the reader. Any data received after all handles are dropped, or received for a registered path, which was never indexed, fails ingress with std::io::ErrorKind::BrokenPipe. Draining is required for transports that reset the connection when closed with unread data, like TCP, discarding data not yet received by the peer.

async fn on_ingress(rx: BufReader<RecvStream>, res: Result<()>)

Handle ingress completion

async fn on_egress(tx: SendStream, res: Result<()>)

Handle egress completion