Module `Dream_h2.Reqd`Source

Sourcemodule Httpaf = Dream_httpaf_.Httpaf

Sourcemodule Writer = Serialize.Writer

Sourcetype error = [

| `Bad_request
| `Internal_server_error
| `Exn of exn

]

type error_handler =
  ?request:Request.t ->
  error ->
  (Headers.t -> Body.Writer.t) ->
  unit

Sourcetype response_state =

| Waiting
| Fixed of {
1. response : Response.t;
2. mutable iovec : [ `String of string | `Bigstring of Bigstringaf.t ] Httpaf.IOVec.t;
}
| Streaming of {
1. response : Response.t;
2. response_body : Body.Writer.t;
3. trailers : Headers.t;
}
| Complete of Response.t

Sourcetype request_info = {

request : Request.t;
request_body : Body.Reader.t;
mutable request_body_bytes : int64;

}

Sourcetype active_state = (request_info, request_info) Stream.active_state

Sourcetype active_stream = {

body_buffer_size : int;
encoder : Dream_h2.Stream.Hpack.Encoder.t;
mutable response_state : response_state;
mutable trailers_parser : Stream.partial_headers option;
mutable trailers : Headers.t option;
create_push_stream : Stream_identifier.t -> (t, [ `Push_disabled | `Stream_ids_exhausted ]) result;

}

Source

and state =
  (active_state, active_stream, request_info * active_stream) Stream.state

Sourceand t = (state, error, error_handler) Stream.stream

Sourceval create_active_request : Request.t -> Body.Reader.t -> request_info

Source

val create_active_stream : 
  Dream_h2.Stream.Hpack.Encoder.t ->
  int ->
  (Stream_identifier.t ->
    (t, [ `Push_disabled | `Stream_ids_exhausted ]) result) ->
  active_stream

Source

val request : 
  (((request_info, request_info) Stream.active_state, 'a, request_info * 'b)
     Stream.state,
    'c,
    'd)
    Stream.stream ->
  Request.t

Source

val request_body : 
  (((request_info, request_info) Stream.active_state, 'a, 'b) Stream.state,
    'c,
    'd)
    Stream.stream ->
  Body.Reader.t

Source

val response : 
  ((('a, 'b) Stream.active_state, active_stream, 'c * active_stream)
     Stream.state,
    'd,
    'e)
    Stream.stream ->
  Response.t option

Source

val response_exn : 
  ((('a, 'b) Stream.active_state, active_stream, 'c * active_stream)
     Stream.state,
    'd,
    'e)
    Stream.stream ->
  Response.t

Source

val send_fixed_response : 
  ((('a, 'b) Stream.active_state, 'c, 'd) Stream.state, 'e, 'f) Stream.stream ->
  active_stream ->
  Response.t ->
  [< `Bigstring of Bigstringaf.t | `String of string ] ->
  unit

Source

val schedule_trailers : 
  ((('a, 'b) Stream.active_state, active_stream, 'c) Stream.state, 'd, 'e)
    Stream.stream ->
  Headers.t ->
  unit

Source

val unsafe_respond_with_data : 
  ((('a, 'b) Stream.active_state, active_stream, 'b * active_stream)
     Stream.state,
    'c,
    'd)
    Stream.stream ->
  Response.t ->
  [< `Bigstring of Bigstringaf.t | `String of string ] ->
  unit

Source

val respond_with_string : 
  ((('a, 'b) Stream.active_state, active_stream, 'b * active_stream)
     Stream.state,
    'c,
    'd)
    Stream.stream ->
  Response.t ->
  string ->
  unit

Source

val respond_with_bigstring : 
  ((('a, 'b) Stream.active_state, active_stream, 'b * active_stream)
     Stream.state,
    'c,
    'd)
    Stream.stream ->
  Response.t ->
  Bigstringaf.t ->
  unit

Source

val send_streaming_response : 
  flush_headers_immediately:bool ->
  ((('a, 'b) Stream.active_state, 'c, 'd) Stream.state, 'e, 'f) Stream.stream ->
  active_stream ->
  Response.t ->
  Body.Writer.t

Source

val unsafe_respond_with_streaming : 
  ((('a, 'b) Stream.active_state, active_stream, 'b * active_stream)
     Stream.state,
    'c,
    'd)
    Stream.stream ->
  flush_headers_immediately:bool ->
  Response.t ->
  Body.Writer.t

Source

val respond_with_streaming : 
  ((('a, 'b) Stream.active_state, active_stream, 'b * active_stream)
     Stream.state,
    'c,
    'd)
    Stream.stream ->
  ?flush_headers_immediately:bool ->
  Response.t ->
  Body.Writer.t

Source

val start_push_stream : 
  ((('a, 'b) Stream.active_state, 'c, 'd) Stream.state, 'e, 'f) Stream.stream ->
  active_stream ->
  Request.t ->
  (t, [ `Push_disabled | `Stream_cant_push | `Stream_ids_exhausted ]) result

Source

val unsafe_push : 
  ((('a, 'b) Stream.active_state, active_stream, 'c) Stream.state, 'd, 'e)
    Stream.stream ->
  Request.t ->
  (t, [ `Push_disabled | `Stream_cant_push | `Stream_ids_exhausted ]) result

Source

val push : 
  ((('a, 'b) Stream.active_state, active_stream, 'c) Stream.state, 'd, 'e)
    Stream.stream ->
  Request.t ->
  (t, [ `Push_disabled | `Stream_cant_push | `Stream_ids_exhausted ]) result

Source

val _report_error : 
  ?request:Request.t ->
  t ->
  active_stream ->
  error ->
  Error_code.t ->
  unit

Source

val report_error : 
  (((request_info, request_info) Stream.active_state,
     active_stream,
     request_info * active_stream)
     Stream.state,
    error,
    error_handler)
    Stream.stream ->
  error ->
  Error_code.t ->
  unit

Source

val report_exn : 
  (((request_info, request_info) Stream.active_state,
     active_stream,
     request_info * active_stream)
     Stream.state,
    error,
    error_handler)
    Stream.stream ->
  exn ->
  unit

Source

val try_with : 
  (((request_info, request_info) Stream.active_state,
     active_stream,
     request_info * active_stream)
     Stream.state,
    error,
    error_handler)
    Stream.stream ->
  (unit -> 'a) ->
  (unit, exn) Result.result

Source

val error_code : 
  ((('a, 'b) Stream.active_state, 'c, 'd) Stream.state,
    [> `Exn of exn ] as 'e,
    'f)
    Stream.stream ->
  'e option

Source

val requires_output : 
  ((('a, 'b) Stream.active_state, active_stream, 'c) Stream.state, 'd, 'e)
    Stream.stream ->
  bool

Source

val flush_request_body : 
  (((request_info, request_info) Stream.active_state,
     active_stream,
     request_info * active_stream)
     Stream.state,
    error,
    error_handler)
    Stream.stream ->
  unit

Source

val write_buffer_data : 
  Dream_h2.Stream.Writer.t ->
  off:int ->
  len:int ->
  Dream_h2__Serialize.frame_info ->
  [< `Bigstring of Bigstringaf.t | `String of string ] ->
  unit

Source

val close_stream : 
  ((('a, 'b) Stream.active_state, 'c, 'd) Stream.state, 'e, 'f) Stream.stream ->
  unit

Source

val flush_response_body : 
  ((('a, 'b) Stream.active_state, active_stream, 'c) Stream.state, 'd, 'e)
    Stream.stream ->
  max_bytes:int ->
  int

Source

val deliver_trailer_headers : 
  ((('a, 'b) Stream.active_state, active_stream, 'c) Stream.state, 'd, 'e)
    Stream.stream ->
  Headers.t ->
  unit

package dream-httpaf

Module Dream_h2.ReqdSource

Module `Dream_h2.Reqd`Source