Struct flo_http_ui::WebSocketHandler
[−]
[src]
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>
[src]
pub fn new() -> WebSocketHandler<CoreController>
[src]
Creates a new websocket handler
pub fn from_sessions(
sessions: Arc<WebSessions<CoreController>>
) -> WebSocketHandler<CoreController>
[src]
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 = ()>>
[src]
&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 = ()>>
[src]
&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'