Module `Dream_h2.Stream`Source

Sourcemodule Hpack = Dream_hpack.Hpack

Sourcemodule AB = Angstrom.Buffered

Sourcemodule Writer = Serialize.Writer

Sourcetype partial_headers = {

mutable parse_state : (Headers.t, Hpack.error) result AB.state;
end_stream : bool;

}

Sourcetype 'active_peer remote_state =

| WaitingForPeer
| PartialHeaders of partial_headers
| FullHeaders
| ActiveMessage of 'active_peer

Sourcetype closed_reason =

| Finished
| ResetByUs of Error_code.t
| ResetByThem of Error_code.t

Sourcetype closed = {

reason : closed_reason;
mutable ttl : int;

}

Sourcetype ('opn, 'half_closed) active_state =

| Open of 'opn remote_state
| HalfClosed of 'half_closed

Sourcetype ('active_state, 'active, 'reserved) state =

| Idle
| Reserved of 'reserved
| Active of 'active_state * 'active
| Closed of closed

constraint 'active_state = (_, _) active_state

Sourcetype 'a error_status =

| No_error
| Exn of exn
| Other of {
1. error : 'a;
2. code : Error_code.t;
}

Sourcetype ('state, 'error, 'error_handler) t = {

id : Stream_identifier.t;
writer : Serialize.Writer.t;
error_handler : 'error_handler;
mutable error_code : 'error error_status;
mutable state : 'state;
mutable max_frame_size : int;
on_close : active:bool -> closed -> unit;

} constraint 'state = (_, _, _) state

Sourceval initial_ttl : int

Source

val create : 
  Stream_identifier.t ->
  max_frame_size:int ->
  Serialize.Writer.t ->
  'a ->
  (active:bool -> closed -> unit) ->
  ((('b, 'c) active_state, 'd, 'e) state, 'f, 'a) t

Source

val id : 
  ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) t ->
  Stream_identifier.t

Sourceval is_idle : ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) t -> bool

Sourceval is_open : ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) t -> bool

Source

val finish_stream : 
  ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) t ->
  closed_reason ->
  unit

Source

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

Sourceval error_to_code : ([> `Exn of exn ] as 'a) -> Error_code.t -> 'a error_status

Source

val reset_stream : 
  ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) t ->
  Error_code.t ->
  unit

Install

dune-project
Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Stream/index.html

Module `Dream_h2.Stream`Source

package dream-httpaf

Install

dune-project Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Stream/index.html

Module Dream_h2.StreamSource

dune-project
Dependency

Module `Dream_h2.Stream`Source