Muxer = ref object of RootObj
  streamHandler*: StreamHandler
  handler*: Future[void].Raising([])
  connection*: Connection

MuxerConstructor = proc (conn: Connection): Muxer {....gcsafe, closure, ...raises: [].}

MuxerError = object of LPError

MuxerHandler = proc (muxer: Muxer): Future[void].Raising([]) {....gcsafe,
    raises: [].}

MuxerProvider = object
  newMuxer*: MuxerConstructor
  codec*: string

StreamHandler = proc (conn: Connection): Future[void].Raising([]) {....gcsafe,
    raises: [].}

TooManyChannels = object of MuxerError

DefaultChanTimeout = (value: 300000000000)

proc new(T: typedesc[MuxerProvider]; creator: MuxerConstructor; codec: string): T:type {.
    ...gcsafe, raises: [].}

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

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

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

method handle(m: Muxer): InternalRaisesFuture[void, void] {.base,
    stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [],
    tags: [RootEffect].}

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

template formatItIMPL(it: Muxer): auto