Types
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
YamuxDefaultWindowSize = 256000
- 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 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 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