pub(all) suberror Refused {
  Incomplete
  FrameSizeError(String)
  ProtocolError(String)
  Connection(code~ : Int, String)
  Order(String)
} derive(Eq)

type Conn

pub(all) enum Event {
  Request(stream~ : Int, fields~ : Array[
@moonbitstack/moonhttp/header.Header
Header])
  Response(stream~ : Int, fields~ : Array[
@moonbitstack/moonhttp/header.Header
Header])
  Informational(stream~ : Int, fields~ : Array[
@moonbitstack/moonhttp/header.Header
Header])
  Trailers(stream~ : Int, fields~ : Array[
@moonbitstack/moonhttp/header.Header
Header])
  Data(stream~ : Int, data~ : Bytes)
  End(stream~ : Int)
  Reset(stream~ : Int, code~ : Int, remote~ : Bool)
  Pushed(stream~ : Int, promised~ : Int, fields~ : Array[
@moonbitstack/moonhttp/header.Header
Header])
  WindowUpdated(stream~ : Int, delta~ : Int)
  Settings(Settings)
  SettingsAcked(Settings)
  Ping(Bytes)
  PingAcked(Bytes)
  GoAway(code~ : Int, last~ : Int, debug~ : Bytes)
  NeedData
  Closed
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) enum Frame {
  Data(stream_id~ : Int, data~ : Bytes, end_stream~ : Bool, padding~ : Int)
  Headers(stream_id~ : Int, fragment~ : Bytes, end_stream~ : Bool, end_headers~ : Bool, priority~ : Priority?, padding~ : Int)
  Priority(stream_id~ : Int, priority~ : Priority)
  RstStream(stream_id~ : Int, error_code~ : Int)
  Settings(params~ : Array[(Int, Int)], ack~ : Bool)
  PushPromise(stream_id~ : Int, promised_id~ : Int, fragment~ : Bytes, end_headers~ : Bool, padding~ : Int)
  Ping(payload~ : Bytes, ack~ : Bool)
  GoAway(last_stream_id~ : Int, error_code~ : Int, debug~ : Bytes)
  WindowUpdate(stream_id~ : Int, increment~ : Int)
  Continuation(stream_id~ : Int, fragment~ : Bytes, end_headers~ : Bool)
  Unknown(ftype~ : Int, flags~ : Int, stream_id~ : Int, payload~ : Bytes)
} derive(Eq)

pub(all) struct FrameHeader {
  length : Int
  ftype : Int
  flags : Int
  stream_id : Int
} derive(Eq)

pub(all) struct Priority {
  exclusive : Bool
  stream_dependency : Int
  weight : Int
} derive(Eq)

pub(all) enum Role {
  Server
  Client
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct Settings {
  header_table_size : Int
  enable_push : Bool
  max_concurrent_streams : Int?
  initial_window_size : Int
  max_frame_size : Int
  max_header_list_size : Int?
  enable_connect_protocol : Bool
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

fn decode(data : Bytes, offset? : Int) -> (Frame, Int) raise Refused

let error_cancel : Int

let error_compression_error : Int

let error_connect_error : Int

let error_enhance_your_calm : Int

let error_flow_control_error : Int

let error_frame_size_error : Int

let error_http_1_1_required : Int

let error_inadequate_security : Int

let error_internal_error : Int

let error_no_error : Int

let error_protocol_error : Int

let error_refused_stream : Int

let error_settings_timeout : Int

let error_stream_closed : Int

let flag_ack : Int

let flag_end_headers : Int

let flag_end_stream : Int

let flag_padded : Int

let flag_priority : Int

let frame_continuation : Int

let frame_data : Int

let frame_goaway : Int

let frame_headers : Int

let frame_ping : Int

let frame_priority : Int

let frame_push_promise : Int

let frame_rst_stream : Int

let frame_settings : Int

let frame_window_update : Int

fn has_preface(data : Bytes) -> Bool

let initial : Settings

let preface : Bytes

let settings : Settings

let settings_enable_connect_protocol : Int

let settings_enable_push : Int

let settings_header_table_size : Int

let settings_initial_window_size : Int

let settings_max_concurrent_streams : Int

let settings_max_frame_size : Int

let settings_max_header_list_size : Int