Module Dream_websocketaf.Server_connectionSource

Sourcemodule IOVec = Httpaf.IOVec
Sourcemodule Server_handshake = Gluten.Server
Sourcetype state =
  1. | Handshake of Server_handshake.t
  2. | Websocket of Websocket_connection.t
Sourcetype t = {
  1. mutable state : state;
  2. websocket_handler : Wsd.t -> Websocket_connection.input_handlers;
}
Sourceval is_closed : t -> bool
Sourceval create : sha1:(string -> string) -> ?error_handler:Wsd.error_handler -> (Wsd.t -> Websocket_connection.input_handlers) -> t
Sourceval create_websocket : ?error_handler:Wsd.error_handler -> (Wsd.t -> Websocket_connection.input_handlers) -> t
Sourceval shutdown : t -> unit
Sourceval report_exn : t -> exn -> unit
Sourceval next_read_operation : t -> [ `Close | `Read | `Yield ]
Sourceval read : t -> Bigstringaf.t -> off:int -> len:int -> int
Sourceval read_eof : t -> Bigstringaf.t -> off:int -> len:int -> int
Sourceval yield_reader : t -> (unit -> unit) -> unit
Sourceval next_write_operation : t -> [ `Close of int | `Write of Bigstringaf.t Faraday.iovec list | `Yield ]
Sourceval report_write_result : t -> [ `Closed | `Ok of int ] -> unit
Sourceval yield_writer : t -> (unit -> unit) -> unit