package ojs_base

  1. Overview
  2. Docs

Class Make.connection_groupSource

val mutable connections : ((Rpc.app_server_msg -> unit Lwt.t) * Rpc.t) list
val mutable handle_message : (Rpc.app_server_msg -> unit Lwt.t) -> Rpc.t -> Rpc.app_client_msg -> unit Lwt.t
method add_connection : Websocket.Frame.t Lwt_stream.t -> (Websocket.Frame.t -> unit Lwt.t) -> unit Lwt.t
method broadcall : Rpc.app_server_msg -> (Rpc.app_client_msg -> unit Lwt.t) -> unit Lwt.t
method broadcast : Rpc.app_server_msg -> unit Lwt.t
method handle_message : (Rpc.app_server_msg -> unit Lwt.t) -> Rpc.t -> Rpc.app_client_msg -> unit Lwt.t
method remove_connection : (Rpc.app_server_msg -> unit Lwt.t) -> unit
method set_handle_message : ((Rpc.app_server_msg -> unit Lwt.t) -> Rpc.t -> Rpc.app_client_msg -> unit Lwt.t) -> unit