Struct flo_http_ui::WebSocketHandler

pub struct WebSocketHandler<CoreController: Controller> { /* fields omitted */ }

Represents a handler for connections to a session using websockets

The websocket handler can't create new sessions and assumes we just want events for existing sessions.

Methods

impl<CoreController: Controller + 'static> WebSocketHandler<CoreController>

pub fn new() -> WebSocketHandler<CoreController>

Creates a new websocket handler

pub fn from_sessions(
    sessions: Arc<WebSessions<CoreController>>
) -> WebSocketHandler<CoreController>

Creates a websocket handler that will provide websockets for a pre-set set of sessions

pub fn handle_incoming_requests(
    &self,
    incoming: Box<Stream<Item = (WsUpgrade<TcpStream, BytesMut>, SocketAddr), Error = InvalidConnection<TcpStream, BytesMut>>>,
    tokio_core_handle: Arc<Handle>
) -> Box<Future<Item = (), Error = ()>>

Handles incoming requests on a websocket connection

pub fn create_server(
    &self,
    bind_address: &str,
    tokio_core_handle: Arc<Handle>
) -> Box<Future<Item = (), Error = ()>>

Creates a websocket. Bind address should be something like '127.0.0.1:3001'

Trait Implementations