Yamux = ref object of Muxer
  channels: Table[uint32, YamuxChannel]
  flushed: Table[uint32, int]
  currentId: uint32
  isClosed: bool
  maxChannCount: int

YamuxChannel = ref object of Connection
  id: uint32
  recvWindow: int
  sendWindow: int
  maxRecvWindow: int
  conn: Connection
  isSrc: bool
  opened: bool
  isSending: bool
  sendQueue: seq[ToSend]
  recvQueue: seq[byte]
  isReset: bool
  remoteReset: bool
  closedRemotely: Future[void]
  closedLocally: bool
  receivedData: AsyncEvent
  returnedEof: bool

YamuxError = object of CatchableError

YamuxCodec = "/yamux/1.0.0"

proc new(T: type[Yamux]; conn: Connection;
         direction: Opt[Direction] = Opt.none(Direction);
         maxChannCount: int = MaxChannelCount): T:type {....raises: [].}

proc open(channel: YamuxChannel): Future[void] {....gcsafe, stackTrace: false,
    ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}

proc setMaxRecvWindow(channel: YamuxChannel; maxRecvWindow: int) {....raises: [],
    tags: [].}

method close(m: Yamux): Future[void] {.stackTrace: false, ...gcsafe, raises: [],
                                       raises: [], raises: [],
                                       tags: [RootEffect].}

method closeImpl(channel: YamuxChannel): Future[void] {....gcsafe,
    stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [],
    tags: [RootEffect].}

method getStreams(m: Yamux): seq[Connection] {....raises: [], tags: [].}

method getWrapped(channel: YamuxChannel): Connection {....raises: [], tags: [].}

method handle(m: Yamux): Future[void] {....gcsafe, stackTrace: false, ...gcsafe,
                                        raises: [], raises: [], raises: [],
                                        tags: [RootEffect].}

method newStream(m: Yamux; name: string = ""; lazy: bool = false): Future[
    Connection] {....gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [],
                  raises: [], tags: [RootEffect].}

method readOnce(channel: YamuxChannel; pbytes: pointer; nbytes: int): Future[int] {.
    stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [],
    tags: [RootEffect].}

method write(channel: YamuxChannel; msg: seq[byte]): Future[void] {....raises: [],
    tags: [RootEffect].}