dream-httpaf 1.0.0~alpha3 (latest)

module PriorityTreeNode : sig ... end

module PriorityQueue : sig ... end

type root = PriorityTreeNode.root =

| Root

type nonroot = PriorityTreeNode.nonroot =

| NonRoot

type stream = nonroot node

and parent = PriorityTreeNode.parent =

| Parent : 'a node -> parent

and !'a node = 'a PriorityTreeNode.node =

| Stream : {
1. descriptor : Respd.t;
2. mutable t_last : int;
3. mutable t : int;
4. mutable priority : Priority.t;
5. mutable parent : parent;
6. mutable children : PriorityQueue.t;
7. mutable flow : Settings.WindowSize.t;
8. mutable inflow : Settings.WindowSize.t;
} -> nonroot node

type t = root node

val make_root : ?capacity:int -> unit -> root node

val create : 
  parent:parent ->
  initial_send_window_size:Settings.WindowSize.t ->
  initial_recv_window_size:Settings.WindowSize.t ->
  Respd.t ->
  nonroot node

val stream_id : 'a node -> int32

val children : 'a node -> PriorityQueue.t

val remove_child : 'a node -> int32 -> unit

val update_children : 'a node -> PriorityQueue.t -> unit

val set_parent : nonroot node -> exclusive:bool -> parent -> unit

val would_create_cycle : new_parent:parent -> nonroot node -> bool

val reprioritize_stream : 
  root node ->
  priority:Priority.t ->
  nonroot node ->
  unit

val update_t : nonroot node -> int -> unit

val update_t_last : 'a node -> int -> unit

val add : 
  root node ->
  priority:Priority.t ->
  initial_send_window_size:Settings.WindowSize.t ->
  initial_recv_window_size:Settings.WindowSize.t ->
  Respd.t ->
  nonroot node

val get_node : root node -> Stream_identifier.t -> stream option

val find : root node -> Stream_identifier.t -> Respd.t option

val iter : root node -> f:(stream -> unit) -> unit

val allowed_to_transmit : root node -> nonroot node -> bool

val allowed_to_receive : 
  root node ->
  nonroot node ->
  Settings.WindowSize.t ->
  bool

val write : root node -> nonroot node -> int

val mark_for_removal : 
  root node ->
  Stream_identifier.t ->
  Stream.closed ->
  unit

val implicitly_close_idle_stream : 
  Respd.t ->
  (Stream_identifier.t * Stream_identifier.t) ->
  unit

val flush : root node -> (Stream_identifier.t * Stream_identifier.t) -> unit

val check_flow : Stdlib.Int32.t -> Stdlib.Int32.t -> Stdlib.Int32.t -> bool

val add_flow : 'a node -> int32 -> bool

val add_inflow : 'a node -> int32 -> bool

val deduct_inflow : 'a node -> int32 -> unit

val pp_hum : Stdlib.Format.formatter -> root node -> unit

package dream-httpaf