Module `Parse.Reader`Source

Sourcemodule AU = Angstrom.Unbuffered

Sourcetype parse_error = [

| `Parse of string list * string
| `Error of Error.t
| `Error_code of Error_code.t

]

Sourcetype 'error parse_state =

| Initial
| Fail of 'error
| Partial of Bigstringaf.t -> off:int -> len:int -> AU.more -> (unit, 'error) result AU.state

Sourcetype 'error t = {

parser : (unit, 'error) result Angstrom.t;
mutable parse_state : 'error parse_state;
mutable closed : bool;
parse_context : parse_context;

}

Sourcetype frame = parse_error t

Sourceval create : (unit, 'a) result Angstrom.t -> parse_context -> 'a t

Sourceval create_parse_context : int -> parse_context

Source

val settings_preface : 
  parse_context ->
  (Frame.t * Settings.settings_list, [> `Error of Error.t ]) result Angstrom.t

Source

val connection_preface_and_frames : 
  max_frame_size:int ->
  (parse_context -> ('a * 'b, 'c) result Angstrom.t) ->
  ('a -> 'b -> 'd) ->
  ((Frame.t, Error.t) result -> 'e) ->
  'c t

Source

val client_frames : 
  (Frame.t -> Settings.settings_list -> 'a) ->
  ((Frame.t, Error.t) result -> 'b) ->
  max_frame_size:int ->
  [> `Error of Error.t ] t

Source

val server_frames : 
  max_frame_size:int ->
  (Frame.t -> Settings.settings_list -> 'a) ->
  ((Frame.t, Error.t) result -> 'b) ->
  [> `Error of Error.t ] t

Sourceval is_closed : 'a t -> bool

Source

val transition : 
  ([> `Error_code of Error_code.t | `Parse of string list * string ] as 'a) t ->
  (unit, 'a) result AU.state ->
  int

Source

val start : 
  ([> `Parse of string list * string ] as 'a) t ->
  (unit, 'a) result AU.state ->
  unit

Source

val read_with_more : 
  [> `Error_code of Error_code.t | `Parse of string list * string ] t ->
  Bigstringaf.t ->
  off:int ->
  len:int ->
  AU.more ->
  int

Sourceval force_close : 'a t -> unit

Sourceval fail_to_string : string list -> string -> string

Source

val next_from_error : 
  'a t ->
  ?msg:string ->
  Error_code.t ->
  [> `Close | `Error of Error.t | `Read ]

Source

val next : 
  [< `Error of Error.t
  | `Error_code of Error_code.t
  | `Parse of string list * string ]
    t ->
  [> `Close | `Error of Error.t | `Read ]

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Parse/Reader/index.html

Module `Parse.Reader`Source

package dream-httpaf

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Parse/Reader/index.html

Module Parse.ReaderSource

Module `Parse.Reader`Source