Struct Dispatcher 

pub struct Dispatcher<U, Err>
where
    U: Encoder + Decoder + 'static,
    Err: 'static,
{ /* private fields */ }

Future that dispatches decoded transport frames to a service.

The service receives DispatchItem values and returns Option<U::Item>, where Some(item) is encoded and written to the transport and None produces no response.

Multiple service calls may be in flight concurrently. When the transport applies write backpressure, the dispatcher pauses normal reads and emits Control::WBackPressureEnabled. It emits Control::WBackPressureDisabled before resuming normal processing.

Before shutdown, transport and codec failures are delivered to the service as DispatchItem::Stop. The future resolves to Err only when the service itself fails. Graceful and protocol stops drain service calls before shutdown; transport failures abandon pending calls after delivering the stop notification so they cannot block teardown.

Implementations

impl<U, Err> Dispatcher<U, Err>

where U: Decoder + Encoder + 'static, Err: 'static,

pub fn new<Io>( io: Io, codec: U, service: Pipeline<DispatchItem<U>, Option<<U as Encoder>::Item>, Err>, ) -> Dispatcher<U, Err>

where IoBoxed: From<Io>,

Creates a dispatcher for an I/O transport, codec, and service pipeline.

Keep-alive and frame-read timeout behavior is taken from the transport’s ntex_io::IoConfig.

pub fn max_inflight(self, max: u32) -> Dispatcher<U, Err>

Sets the maximum number of concurrent service calls.

The dispatcher stops reading frames while max calls are in flight and resumes once a call completes. By default the number of calls is not limited.

Panics

Panics if max is zero.

Trait Implementations

impl<U, Err> Debug for Dispatcher<U, Err>

where U: Encoder + Decoder,

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

Formats the value using the given formatter.

impl<U, Err> Future for Dispatcher<U, Err>

where U: Decoder + Encoder + 'static, Err: 'static,

type Output = Result<(), Err>

The type of value produced on completion.

fn poll( self: Pin<&mut Dispatcher<U, Err>>, cx: &mut Context<'_>, ) -> Poll<<Dispatcher<U, Err> as Future>::Output>

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<U, Err> Unpin for Dispatcher<U, Err>

where U: Encoder + Decoder,