Struct Input 

pub struct Input { /* private fields */ }

图输入口句柄(热路径免按名字查表)。

Implementations

impl Input

pub fn send(&self, pkt: Packet) -> Result<()>

Sends on the same input are serialized through dispatch. Reentrant sends from that input’s dispatch callback return a state error.

pub fn try_send(&self, pkt: Packet) -> Result<()>

Returns WouldBlock if another thread is dispatching on this input.

pub fn backpressure_stats(&self) -> WatermarkBackpressureStatsSnapshot

pub fn close(&self)

Wait for the current send to finish before closing. From this input’s callback, closure is deferred until its current dispatch has finished.

Trait Implementations

impl Debug for Input

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

Formats the value using the given formatter.