Types
InvalidChannelIdError = object of MuxerError
- Source Edit
Consts
MplexCodec = "/mplex/6.7.0"
- Source Edit
Procs
proc new(M: type Mplex; conn: Connection; inTimeout: Duration = DefaultChanTimeout; outTimeout: Duration = DefaultChanTimeout; maxChannCount: int = MaxChannelCount): Mplex {....raises: [].}
- Source Edit
proc newStreamInternal(m: Mplex; initiator: bool = true; chanId: uint64 = 0; name: string = ""; timeout: Duration): LPChannel {. ...gcsafe, raises: [InvalidChannelIdError], raises: [], tags: [TimeEffect, RootEffect], forbids: [].}
- create new channel/stream Source Edit
Methods
method getStreams(m: Mplex): seq[Connection] {....gcsafe, raises: [], tags: [], forbids: [].}
- Source Edit
method newStream(m: Mplex; name: string = ""; lazy: bool = false): InternalRaisesFuture[ Connection, (CancelledError, LPStreamError, MuxerError)] {. ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
- Source Edit
Templates
template formatItIMPL(it: Mplex): auto {..}
- Source Edit