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 = 262144
- Source Edit
Procs
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[MuxedStream] {....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[ MuxedStream, (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 resetImpl(channel: YamuxChannel): InternalRaisesFuture[void, void] {. ...stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
- Source Edit
method write(channel: YamuxChannel; msg: sink seq[byte]): InternalRaisesFuture[ void, (CancelledError, LPStreamError)] {....stackTrace: false, raises: [], gcsafe, raises: [], tags: [RootEffect], forbids: [].}
- Source Edit