Server (u.384930bf29f41c0e93d6110fb739e527.ojs_base.0.7.0.doc.ojs_base.server.Ojs

module J = Yojson.Safe

module SMap : Map.S with type key = string

val mk_msg_of_wsdata : (J.t -> ('a, string) result) -> string -> 'a option

val mk_send_msg : 
  ('a -> string) ->
  (Websocket.Frame.t -> unit Lwt.t) ->
  'a ->
  unit Lwt.t

val mk_msg_stream : 
  (string -> 'a option) ->
  Websocket.Frame.t Lwt_stream.t ->
  'a Lwt_stream.t

val handle_messages : 
  (string -> 'a option) ->
  ('b -> string) ->
  (('b -> unit Lwt.t) -> unit Lwt.t) ->
  Websocket.Frame.t Lwt_stream.t ->
  (Websocket.Frame.t -> unit Lwt.t) ->
  unit Lwt.t

module type P = sig ... end

module type S = sig ... end

module Make
  (P : P) : 
  S
    with type Rpc.app_server_msg = P.app_server_msg
     and type Rpc.app_client_msg = P.app_client_msg