Module Dream_h2.StreamSource

Sourcemodule Writer = Serialize.Writer
Sourcetype partial_headers = {
  1. mutable parse_state : (Headers.t, Hpack.error) result AB.state;
  2. end_stream : bool;
}
Sourcetype 'active_peer remote_state =
  1. | WaitingForPeer
  2. | PartialHeaders of partial_headers
  3. | FullHeaders
  4. | ActiveMessage of 'active_peer
Sourcetype closed_reason =
  1. | Finished
  2. | ResetByUs of Error_code.t
  3. | ResetByThem of Error_code.t
Sourcetype closed = {
  1. reason : closed_reason;
  2. mutable ttl : int;
}
Sourcetype ('opn, 'half_closed) active_state =
  1. | Open of 'opn remote_state
  2. | HalfClosed of 'half_closed
Sourcetype ('active_state, 'active, 'reserved) state =
  1. | Idle
  2. | Reserved of 'reserved
  3. | Active of 'active_state * 'active
  4. | Closed of closed
constraint 'active_state = (_, _) active_state
Sourcetype 'a error_status =
  1. | No_error
  2. | Exn of exn
  3. | Other of {
    1. error : 'a;
    2. code : Error_code.t;
    }
Sourcetype ('state, 'error, 'error_handler) stream = {
  1. id : Stream_identifier.t;
  2. writer : Serialize.Writer.t;
  3. error_handler : 'error_handler;
  4. mutable error_code : 'error error_status;
  5. mutable state : 'state;
  6. mutable max_frame_size : int;
  7. on_close : active:bool -> closed -> unit;
} constraint 'state = (_, _, _) state
Sourceval initial_ttl : int
Sourceval 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) stream
Sourceval id : ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) stream -> Stream_identifier.t
Sourceval is_idle : ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) stream -> bool
Sourceval is_open : ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) stream -> bool
Sourceval finish_stream : ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) stream -> closed_reason -> unit
Sourceval error_code : ((('a, 'b) active_state, 'c, 'd) state, [> `Exn of exn ] as 'e, 'f) stream -> 'e option
Sourceval error_to_code : ([> `Exn of exn ] as 'a) -> Error_code.t -> 'a error_status
Sourceval reset_stream : ((('a, 'b) active_state, 'c, 'd) state, 'e, 'f) stream -> Error_code.t -> unit