libp2p/muxers/yamux/yamux

Search:
Group by:
Source   Edit  

Types

Yamux = ref object of Muxer
Source   Edit  
YamuxChannel = ref object of Connection
Source   Edit  
YamuxError = object of MuxerError
Source   Edit  

Consts

MaxChannelCount = 256
Source   Edit  
YamuxCodec = "/yamux/1.0.0"
Source   Edit  

Procs

proc new(T: type[Yamux]; conn: Connection; maxChannCount: int = MaxChannelCount;
         windowSize: int = YamuxDefaultWindowSize;
         maxSendQueueSize: int = MaxSendQueueSize;
         inTimeout: Duration = 5.minutes; outTimeout: Duration = 5.minutes): T:type {.
    ...raises: [].}
Source   Edit  
proc setMaxRecvWindow(channel: YamuxChannel; maxRecvWindow: int) {....raises: [],
    tags: [], forbids: [].}
Source   Edit  

Methods

method close(m: Yamux): InternalRaisesFuture[void, void] {....stackTrace: false,
    raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
Source   Edit  
method closeImpl(channel: YamuxChannel): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect],
    forbids: [].}
Source   Edit  
method closeWrite(channel: YamuxChannel): InternalRaisesFuture[void, void] {.
    ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect],
    forbids: [].}
For yamux, closeWrite is the same as close - it implements half-close Source   Edit  
method getStreams(m: Yamux): seq[Connection] {....gcsafe, raises: [], tags: [],
    forbids: [].}
Source   Edit  
method getWrapped(channel: YamuxChannel): Connection {....raises: [], tags: [],
    forbids: [].}
Source   Edit  
method handle(m: Yamux): InternalRaisesFuture[void, void] {....stackTrace: false,
    raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
Source   Edit  
method newStream(m: Yamux; name: string = ""; lazy: bool = false): InternalRaisesFuture[
    Connection, (CancelledError, LPStreamError, MuxerError)] {.
    ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect],
    forbids: [].}
Source   Edit  
method readOnce(channel: YamuxChannel; pbytes: pointer; nbytes: int): InternalRaisesFuture[
    int, (CancelledError, LPStreamError)] {....stackTrace: false, raises: [],
    gcsafe, raises: [], tags: [RootEffect], forbids: [].}
Read from a yamux channel Source   Edit  
method write(channel: YamuxChannel; msg: seq[byte]): InternalRaisesFuture[void,
    (CancelledError, LPStreamError)] {....stackTrace: false, raises: [], gcsafe,
                                       raises: [], tags: [RootEffect],
                                       forbids: [].}
Source   Edit