pub(crate) fn debug<T: IoStream, F: IntoService<S, DispatchItem<U>>>(
            io: T,
            codec: U,
            service: F,
        ) -> (Self, State) {
            let state = Io::new(io);
            let ka_timeout = Cell::new(Seconds(1).into());
            let shared = Rc::new(DispatcherShared {
                codec,
                error: Cell::new(None),
                inflight: Cell::new(0),
            });
            let inner = State(state.get_ref());
            state.start_keepalive_timer(Duration::from_millis(500));

            (
                Dispatcher {
                    service: service.into_service(),
                    fut: None,
                    inner: DispatcherInner {
                        error: Cell::new(None),
                        flags: Cell::new(super::Flags::empty()),
                        st: Cell::new(DispatcherState::Processing),
                        pool: state.memory_pool().pool(),
                        io: state.into(),
                        shared,
                        ka_timeout,
                    },
                },
                inner,
            )
        }
/// Construct new `Dispatcher` instance
Construct new `Dispatcher` instance
Construct new ` Dispatcher ` instance
pub(crate) fn debug<T: IoStream, F: IntoService<S, DispatchItem<U>>>(
            io: T,
            codec: U,
            service: F,
        ) -> (Self, State) {
            let state = Io::new(io);
            let ka_timeout = Cell::new(Seconds(1).into());
            let shared = Rc::new(DispatcherShared {
                codec,
                error: Cell::new(None),
                inflight: Cell::new(0),
            });
            let inner = State(state.get_ref());
            state.start_keepalive_timer(Duration::from_millis(500));
            (
                Dispatcher {
                    service: service.into_service(),
                    fut: None,
                    inner: DispatcherInner {
                        error: Cell::new(None),
                        flags: Cell::new(super::Flags::empty()),
                        st: Cell::new(DispatcherState::Processing),
                        pool: state.memory_pool().pool(),
                        io: state.into(),
                        shared,
                        ka_timeout,
                    },
                },
                inner,
            )
        }
pub ( crate ) fn debug < T : IoStream , F : IntoService < S , DispatchItem < U > > > ( io : T , codec : U , service : F , ) -> ( Self , State ) { let state = Io :: new ( io ) ; let ka_timeout = Cell :: new ( Seconds ( 1 ) . into ( ) ) ; let shared = Rc :: new ( DispatcherShared { codec , error : Cell :: new ( None ) , inflight : Cell :: new ( 0 ) , } ) ; let inner = State ( state . get_ref ( ) ) ; state . start_keepalive_timer ( Duration :: from_millis ( 500 ) ) ; ( Dispatcher { service : service . into_service ( ) , fut : None , inner : DispatcherInner { error : Cell :: new ( None ) , flags : Cell :: new ( super :: Flags :: empty ( ) ) , st : Cell :: new ( DispatcherState :: Processing ) , pool : state . memory_pool ( ) . pool ( ) , io : state . into ( ) , shared , ka_timeout , } , } , inner , ) }
Construct new `Dispatcher` instance
Construct new ` Dispatcher ` instance
io
T
codec
U
service
F
io
T
codec
U
service
F