pub fn with<F: IntoService<S>>(
        framed: Framed<T, U>,
        sink: Option<In>,
        service: F,
    ) -> Self {
        Dispatcher {
            inner: InnerDispatcher {
                framed,
                sink,
                rx: mpsc::channel().1,
                service: service.into_service(),
                state: FramedState::Processing,
                disconnect_timeout: 1000,
            },
        }
    }
/// Construct new `Dispatcher` instance with outgoing messages stream.
Construct new `Dispatcher` instance with outgoing messages stream.
Construct new ` Dispatcher ` instance with outgoing messages stream .
pub fn with<F: IntoService<S>>(
        framed: Framed<T, U>,
        sink: Option<In>,
        service: F,
    ) -> Self {
        Dispatcher {
            inner: InnerDispatcher {
                framed,
                sink,
                rx: mpsc::channel().1,
                service: service.into_service(),
                state: FramedState::Processing,
                disconnect_timeout: 1000,
            },
        }
    }
pub fn with < F : IntoService < S > > ( framed : Framed < T , U > , sink : Option < In > , service : F , ) -> Self { Dispatcher { inner : InnerDispatcher { framed , sink , rx : mpsc :: channel ( ) . 1 , service : service . into_service ( ) , state : FramedState :: Processing , disconnect_timeout : 1000 , } , } }
Construct new `Dispatcher` instance with outgoing messages stream.
Construct new ` Dispatcher ` instance with outgoing messages stream .
framed
Framed<T, U>
sink
Option<In>
service
F