Struct tk_http::server::buffered::WebsocketService

pub struct WebsocketService<H, I, T, U> { /* fields omitted */ }

An instance of websocket factory, created by WebsocketFactory itself

Trait Implementations

impl<S: Io, H, I, T, U> Service<S> for WebsocketService<H, I, T, U> where H: Fn(Request, Encoder<S>) -> T,
        I: Fn(WriteFramed<S, WebsocketCodec>, ReadFramed<S, WebsocketCodec>) -> U,
        T: Future<Item=EncoderDone<S>, Error=Error>,
        U: Future<Item=(), Error=()> + 'static

type Future = T

A future returned by call()

type WebsocketFuture = U

A future returned by start_websocket, it's spawned on the main loop hence needed to be static.

fn call(&mut self, request: Request, encoder: Encoder<S>) -> T

A method which is called when request arrives, including the websocket negotiation request.

fn start_websocket(&mut self,
                   output: WriteFramed<S, WebsocketCodec>,
                   input: ReadFramed<S, WebsocketCodec>)
                   -> U

A method which is called when websocket connection established