Module Dream_websocketaf.Websocket_connectionSource

Sourcemodule IOVec = Httpaf.IOVec
Sourcemodule Reader = Parse.Reader
Sourcetype error = [
  1. | `Exn of exn
]
Sourcetype error_handler = Wsd.t -> error -> unit
Sourcetype t = {
  1. reader : [ `Parse of string list * string ] Reader.t;
  2. wsd : Wsd.t;
  3. eof : unit -> unit;
}
Sourcetype input_handlers = {
  1. frame : opcode:Websocket.Opcode.t -> is_fin:bool -> len:int -> Payload.t -> unit;
  2. eof : unit -> unit;
}
Sourceval random_int32 : unit -> Int32.t
Sourceval default_error_handler : Wsd.t -> [< `Exn of exn ] -> unit
Sourceval create : mode:Wsd.mode -> ?error_handler:Wsd.error_handler -> (Wsd.t -> input_handlers) -> t
Sourceval shutdown : t -> unit
Sourceval set_error_and_handle : t -> Wsd.error -> unit
Sourceval next_read_operation : t -> [> `Close | `Read ]
Sourceval next_write_operation : t -> [> `Close of int | `Write of Faraday.bigstring Faraday.iovec list | `Yield ]
Sourceval read : t -> Bigstringaf.t -> off:int -> len:int -> int
Sourceval read_eof : t -> Bigstringaf.t -> off:int -> len:int -> int
Sourceval report_write_result : t -> [< `Closed | `Ok of int ] -> unit
Sourceval yield_writer : t -> (unit -> unit) -> unit
Sourceval is_closed : t -> bool
Sourceval report_exn : t -> exn -> unit
Sourceval yield_reader : 'a -> 'b -> unit