InvalidChannelIdError = object of MuxerError

Mplex = ref object of Muxer
  channels: array[bool, Table[uint64, LPChannel]]
  currentId: uint64
  inChannTimeout: Duration
  outChannTimeout: Duration
  isClosed: bool
  oid*: Oid
  maxChannCount: int

MplexCodec = "/mplex/6.7.0"

proc new(M: type Mplex; conn: Connection;
         inTimeout: Duration = DefaultChanTimeout;
         outTimeout: Duration = DefaultChanTimeout;
         maxChannCount: int = MaxChannelCount): Mplex {....raises: [].}

func shortLog(m: Mplex): auto {....raises: [], tags: [].}

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

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

method newStream(m: Mplex; name: string = ""; lazy: bool = false): InternalRaisesFuture[
    Connection, (CancelledError, LPStreamError, MuxerError)] {.
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}

template formatItIMPL(it: Mplex): auto