libp2p/muxers/mplex/mplex

Search:
Group by:
Source   Edit  

Types

Mplex = ref object of Muxer
  oid*: Oid
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  
func shortLog(m: Mplex): auto {....raises: [], tags: [], forbids: [].}
Source   Edit  

Methods

method close(m: Mplex): InternalRaisesFuture[void, void] {....stackTrace: false,
    raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
Source   Edit  
method getStreams(m: Mplex): seq[Connection] {....gcsafe, raises: [], tags: [],
    forbids: [].}
Source   Edit  
method handle(m: Mplex): InternalRaisesFuture[void, void] {....stackTrace: false,
    raises: [], gcsafe, raises: [], tags: [RootEffect], 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