Module `Serialize.Writer`Source

Sourcetype t = {

buffer : Bigstringaf.t;
encoder : Faraday.t;
mutable drained_bytes : int;
mutable wakeup : Optional_thunk.t;

}

Sourceval create : int -> t

Sourceval faraday : t -> Faraday.t

val make_frame_info : 
  ?padding:Bigstringaf.t ->
  ?flags:Flags.t ->
  ?max_frame_size:int ->
  Stream_identifier.t ->
  frame_info

Sourceval write_connection_preface : t -> Settings.setting list -> unit

Source

val chunk_data_frames : 
  ?off:int ->
  f:(off:int -> len:int -> frame_info -> 'a) ->
  frame_info ->
  int ->
  'a

Sourceval write_data : t -> frame_info -> ?off:int -> ?len:int -> string -> unit

Source

val schedule_data : 
  t ->
  frame_info ->
  ?off:int ->
  ?len:int ->
  Bigstringaf.t ->
  unit

Source

val chunk_header_block_fragments : 
  t ->
  frame_info ->
  ?has_priority:bool ->
  write_frame:
    (Faraday.t ->
      frame_info ->
      ?len:int ->
      Bigstringaf.t Faraday.iovec list ->
      unit) ->
  Faraday.t ->
  unit

Source

val encode_headers : 
  Hpack.Encoder.t ->
  Faraday.t ->
  Dream_hpack__Hpack.header list ->
  unit

Source

val write_request_like_frame : 
  t ->
  Hpack.Encoder.t ->
  write_frame:
    (Faraday.t ->
      frame_info ->
      ?len:int ->
      Bigstringaf.t Faraday.iovec list ->
      unit) ->
  frame_info ->
  Request.t ->
  unit

Source

val write_request_headers : 
  t ->
  Hpack.Encoder.t ->
  priority:Priority.t ->
  frame_info ->
  Request.t ->
  unit

Source

val write_push_promise : 
  t ->
  Hpack.Encoder.t ->
  frame_info ->
  promised_id:int32 ->
  Request.t ->
  unit

Source

val write_response_headers : 
  t ->
  Hpack.Encoder.t ->
  frame_info ->
  Response.t ->
  unit

Source

val write_response_trailers : 
  t ->
  Hpack.Encoder.t ->
  frame_info ->
  Dream_hpack__Hpack.header list ->
  unit

Sourceval write_rst_stream : t -> frame_info -> Error_code.t -> unit

Sourceval write_window_update : t -> frame_info -> int32 -> unit

Source

val schedule_iovecs : 
  t ->
  len:int ->
  frame_info ->
  Faraday.bigstring IOVec.t list ->
  unit

Sourceval write_priority : t -> frame_info -> Priority.t -> unit

Sourceval write_settings : t -> frame_info -> Settings.setting list -> unit

Sourceval write_ping : t -> frame_info -> ?off:int -> Faraday.bigstring -> unit

Source

val write_go_away : 
  t ->
  frame_info ->
  debug_data:Bigstringaf.t ->
  last_stream_id:int32 ->
  Error_code.t ->
  unit

Sourceval on_wakeup_writer : t -> (unit -> unit) -> unit

Sourceval wakeup : t -> unit

Sourceval flush : t -> (unit -> unit) -> unit

Sourceval unyield : t -> unit

Sourceval yield : t -> unit

Sourceval close : t -> unit

Sourceval close_and_drain : t -> unit

Sourceval is_closed : t -> bool

Sourceval drained_bytes : t -> int

Sourceval report_result : t -> [< `Closed | `Ok of int ] -> unit

Source

val next : 
  t ->
  [> `Close of int | `Write of Faraday.bigstring Faraday.iovec list | `Yield ]

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Serialize/Writer/index.html

Module `Serialize.Writer`Source

package dream-httpaf

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Serialize/Writer/index.html

Module Serialize.WriterSource

Module `Serialize.Writer`Source