diff --git a/unstable/libp2p.html b/unstable/libp2p.html index fc2c8caf5..3f3ea8c20 100644 --- a/unstable/libp2p.html +++ b/unstable/libp2p.html @@ -260,7 +260,7 @@ class="link-seesrc" target="_blank">Source
diff --git a/unstable/libp2p/builders.html b/unstable/libp2p/builders.html index 81dabaace..77ff9f636 100644 --- a/unstable/libp2p/builders.html +++ b/unstable/libp2p/builders.html @@ -801,7 +801,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/connmanager.html b/unstable/libp2p/connmanager.html index aba55e399..7d3a048d7 100644 --- a/unstable/libp2p/connmanager.html +++ b/unstable/libp2p/connmanager.html @@ -874,7 +874,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/chacha20poly1305.html b/unstable/libp2p/crypto/chacha20poly1305.html index c26c94d37..c1212451b 100644 --- a/unstable/libp2p/crypto/chacha20poly1305.html +++ b/unstable/libp2p/crypto/chacha20poly1305.html @@ -391,7 +391,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/crypto.html b/unstable/libp2p/crypto/crypto.html index e3633048f..4865517d1 100644 --- a/unstable/libp2p/crypto/crypto.html +++ b/unstable/libp2p/crypto/crypto.html @@ -1703,7 +1703,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/curve25519.html b/unstable/libp2p/crypto/curve25519.html index 0c047dedb..4f932d225 100644 --- a/unstable/libp2p/crypto/curve25519.html +++ b/unstable/libp2p/crypto/curve25519.html @@ -398,7 +398,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/ecnist.html b/unstable/libp2p/crypto/ecnist.html index 05a892e71..883b9509b 100644 --- a/unstable/libp2p/crypto/ecnist.html +++ b/unstable/libp2p/crypto/ecnist.html @@ -1450,7 +1450,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/ed25519/constants.html b/unstable/libp2p/crypto/ed25519/constants.html index a29c5fb5b..725159928 100644 --- a/unstable/libp2p/crypto/ed25519/constants.html +++ b/unstable/libp2p/crypto/ed25519/constants.html @@ -3040,7 +3040,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/ed25519/ed25519.html b/unstable/libp2p/crypto/ed25519/ed25519.html index a2b11220d..81aa7513d 100644 --- a/unstable/libp2p/crypto/ed25519/ed25519.html +++ b/unstable/libp2p/crypto/ed25519/ed25519.html @@ -940,7 +940,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/hkdf.html b/unstable/libp2p/crypto/hkdf.html index fc190ba1b..70844b9d8 100644 --- a/unstable/libp2p/crypto/hkdf.html +++ b/unstable/libp2p/crypto/hkdf.html @@ -275,7 +275,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/minasn1.html b/unstable/libp2p/crypto/minasn1.html index 412c31f87..74165d45a 100644 --- a/unstable/libp2p/crypto/minasn1.html +++ b/unstable/libp2p/crypto/minasn1.html @@ -1195,7 +1195,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/rsa.html b/unstable/libp2p/crypto/rsa.html index c19f4ce3e..929240b64 100644 --- a/unstable/libp2p/crypto/rsa.html +++ b/unstable/libp2p/crypto/rsa.html @@ -1029,7 +1029,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/secp.html b/unstable/libp2p/crypto/secp.html index c268bd718..3504e6ec9 100644 --- a/unstable/libp2p/crypto/secp.html +++ b/unstable/libp2p/crypto/secp.html @@ -908,7 +908,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/dial.html b/unstable/libp2p/dial.html index d519752f9..f57d0852e 100644 --- a/unstable/libp2p/dial.html +++ b/unstable/libp2p/dial.html @@ -381,7 +381,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/dialer.html b/unstable/libp2p/dialer.html index 7e04fb693..890ac9aff 100644 --- a/unstable/libp2p/dialer.html +++ b/unstable/libp2p/dialer.html @@ -450,7 +450,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/errors.html b/unstable/libp2p/errors.html index 53ad7b942..4aa57651d 100644 --- a/unstable/libp2p/errors.html +++ b/unstable/libp2p/errors.html @@ -340,7 +340,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/multiaddress.html b/unstable/libp2p/multiaddress.html index 4bb1d9342..f16af1b9e 100644 --- a/unstable/libp2p/multiaddress.html +++ b/unstable/libp2p/multiaddress.html @@ -2551,7 +2551,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/multibase.html b/unstable/libp2p/multibase.html index f34920bb7..b33fdf70a 100644 --- a/unstable/libp2p/multibase.html +++ b/unstable/libp2p/multibase.html @@ -396,7 +396,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/multicodec.html b/unstable/libp2p/multicodec.html index 7e555dfc4..ee3cdf1c8 100644 --- a/unstable/libp2p/multicodec.html +++ b/unstable/libp2p/multicodec.html @@ -481,7 +481,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/multihash.html b/unstable/libp2p/multihash.html index 733c65b34..d030b099b 100644 --- a/unstable/libp2p/multihash.html +++ b/unstable/libp2p/multihash.html @@ -689,7 +689,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/multistream.html b/unstable/libp2p/multistream.html index 49b374573..9b65e0782 100644 --- a/unstable/libp2p/multistream.html +++ b/unstable/libp2p/multistream.html @@ -539,7 +539,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/muxers/mplex/coder.html b/unstable/libp2p/muxers/mplex/coder.html index 647077333..0b93b3602 100644 --- a/unstable/libp2p/muxers/mplex/coder.html +++ b/unstable/libp2p/muxers/mplex/coder.html @@ -233,18 +233,22 @@ window.addEventListener("DOMContentLoaded", main2);proc readMsg(conn: Connection): Future[Msg] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
proc readMsg(conn: Connection): InternalRaisesFuture[Msg, + (CancelledError, LPStreamError, MuxerError)] {.stackTrace: false, + ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
proc writeMsg(conn: Connection; id: uint64; msgType: MessageType; - data: seq[byte] = @[]): Future[void] {....raises: [], tags: [].}
proc writeMsg(conn: Connection; id: uint64; msgType: MessageType; data: string): Future[ - void] {....raises: [], tags: [].}
proc writeMsg(conn: Connection; id: uint64; msgType: MessageType; data: string): InternalRaisesFuture[ + void, (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], tags: [].}
method close(m: Mplex): Future[void] {.stackTrace: false, ...raises: [], gcsafe, - raises: [], raises: [], - tags: [RootEffect].}
method close(m: Mplex): InternalRaisesFuture[void, void] {.stackTrace: false, + ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
method newStream(m: Mplex; name: string = ""; lazy: bool = false): Future[ - Connection] {.stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method newStream(m: Mplex; name: string = ""; lazy: bool = false): InternalRaisesFuture[ + Connection, (CancelledError, LPStreamError, MuxerError)] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
Muxer = ref object of RootObj streamHandler*: StreamHandler - handler*: Future[void] + handler*: Future[void].Raising([]) connection*: Connection
MuxerHandler = proc (muxer: Muxer): Future[void] {....gcsafe, raises: [].}
MuxerHandler = proc (muxer: Muxer): Future[void] {.async: (...raises: []).}
StreamHandler = proc (conn: Connection): Future[void] {....gcsafe, raises: [].}
StreamHandler = proc (conn: Connection): Future[void] {.async: (...raises: []).}
method close(m: Muxer): Future[void] {.base, stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method close(m: Muxer): InternalRaisesFuture[void, void] {.base, + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method handle(m: Muxer): Future[void] {.base, stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method handle(m: Muxer): InternalRaisesFuture[void, void] {.base, + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method newStream(m: Muxer; name: string = ""; lazy: bool = false): Future[ - Connection] {.base, stackTrace: false, ...raises: [], gcsafe, raises: [], - raises: [], tags: [RootEffect].}
method newStream(m: Muxer; name: string = ""; lazy: bool = false): InternalRaisesFuture[ + Connection, (CancelledError, LPStreamError, MuxerError)] {.base, + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], tags: [].}
method close(m: Yamux): Future[void] {.stackTrace: false, ...raises: [], gcsafe, - raises: [], raises: [], - tags: [RootEffect].}
method closeImpl(channel: YamuxChannel): Future[void] {.stackTrace: false, +
method close(m: Yamux): InternalRaisesFuture[void, void] {.stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
method closeImpl(channel: YamuxChannel): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method handle(m: Yamux): Future[void] {.stackTrace: false, ...raises: [], gcsafe, - raises: [], raises: [], - tags: [RootEffect].}
method handle(m: Yamux): InternalRaisesFuture[void, void] {.stackTrace: false, + ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
method newStream(m: Yamux; name: string = ""; lazy: bool = false): Future[ - Connection] {.stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method readOnce(channel: YamuxChannel; pbytes: pointer; nbytes: int): Future[int] {. +
method newStream(m: Yamux; name: string = ""; lazy: bool = false): InternalRaisesFuture[ + Connection, (CancelledError, LPStreamError, MuxerError)] {. stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
method readOnce(channel: YamuxChannel; pbytes: pointer; nbytes: int): InternalRaisesFuture[ + int, (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], tags: [RootEffect].}
method write(channel: YamuxChannel; msg: seq[byte]): Future[void] {....raises: [], - tags: [RootEffect].}
method write(channel: YamuxChannel; msg: seq[byte]): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], gcsafe, + raises: [], raises: [], + tags: [RootEffect].}
method closeImpl(self: RelayConnection): Future[void] {.stackTrace: false, - ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
method getWrapped(self: RelayConnection): Connection {....raises: [], tags: [].}
method closeImpl(self: RelayConnection): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method readOnce(self: RelayConnection; pbytes: pointer; nbytes: int): Future[int] {. - stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method getWrapped(self: RelayConnection): Connection {....raises: [], tags: [].}
method readOnce(self: RelayConnection; pbytes: pointer; nbytes: int): InternalRaisesFuture[ + int, (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], tags: [].}
method write(self: RelayConnection; msg: seq[byte]): Future[void] {. - stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method write(self: RelayConnection; msg: seq[byte]): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], gcsafe, + raises: [], raises: [], + tags: [RootEffect].}
method closeImpl(s: NoiseConnection): Future[void] {.stackTrace: false, - ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
method closeImpl(s: NoiseConnection): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method readMessage(sconn: NoiseConnection): Future[seq[byte]] {. - stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method readMessage(sconn: NoiseConnection): InternalRaisesFuture[seq[byte], + (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], gcsafe, + raises: [], raises: [], + tags: [RootEffect].}
method write(sconn: NoiseConnection; message: seq[byte]): Future[void] {. - ...raises: [], tags: [WriteIOEffect, TimeEffect].}
method write(sconn: NoiseConnection; message: seq[byte]): InternalRaisesFuture[ + void, (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], tags: [WriteIOEffect, TimeEffect].}
method closeImpl(s: SecureConn): Future[void] {.stackTrace: false, ...raises: [], - gcsafe, gcsafe, raises: [], gcsafe, raises: [], tags: [RootEffect].}
method closeImpl(s: SecureConn): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [RootEffect].}
method readMessage(c: SecureConn): Future[seq[byte]] {.base, stackTrace: false, - ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, raises: [], - tags: [RootEffect].}
method readMessage(c: SecureConn): InternalRaisesFuture[seq[byte], + (CancelledError, LPStreamError)] {.base, stackTrace: false, ...raises: [], + gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [].}
method readOnce(s: SecureConn; pbytes: pointer; nbytes: int): Future[int] {. - stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, - raises: [], tags: [RootEffect].}
method readOnce(s: SecureConn; pbytes: pointer; nbytes: int): InternalRaisesFuture[ + int, (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], + gcsafe, gcsafe, raises: [], gcsafe, raises: [], tags: [RootEffect].}
method closeImpl(s: BufferStream): Future[void] {....raises: [], tags: [RootEffect].}
method closeImpl(s: BufferStream): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method pushData(s: BufferStream; data: seq[byte]): Future[void] {.base, - stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method pushData(s: BufferStream; data: seq[byte]): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.base, stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], + tags: [RootEffect].}
Write bytes to internal read buffer, use this to fill up the buffer with data.
pushTo will block if the queue is full, thus maintaining backpressure.
Source - Edit + Editmethod pushEof(s: BufferStream): Future[void] {.base, stackTrace: false, - ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
method pushEof(s: BufferStream): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.base, stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method readOnce(s: BufferStream; pbytes: pointer; nbytes: int): Future[int] {. - stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method readOnce(s: BufferStream; pbytes: pointer; nbytes: int): InternalRaisesFuture[ + int, (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], tags: [RootEffect].}
method closeImpl(s: ChronosStream): Future[void] {.stackTrace: false, - ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
method closeImpl(s: ChronosStream): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method readOnce(s: ChronosStream; pbytes: pointer; nbytes: int): Future[int] {. - stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method readOnce(s: ChronosStream; pbytes: pointer; nbytes: int): InternalRaisesFuture[ + int, (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], tags: [RootEffect].}
method write(s: ChronosStream; msg: seq[byte]): Future[void] {....raises: [], - tags: [RootEffect].}
method write(s: ChronosStream; msg: seq[byte]): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], gcsafe, + raises: [], raises: [], + tags: [RootEffect].}
Connection = ref object of LPStream activity*: bool timeout*: Duration - timerTaskFut: Future[void] + timerTaskFut: Future[void].Raising([]) timeoutHandler*: TimeoutHandler peerId*: PeerId observedAddr*: Opt[MultiAddress] @@ -343,7 +343,7 @@ class="link-seesrc" target="_blank">Source-@@ -409,9 +409,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -433,14 +433,16 @@ class="link-seesrc" target="_blank">Source- +
TimeoutHandler = proc (): Future[void] {....gcsafe, raises: [].} TimeoutHandler = proc (): Future[void] {.async: (...raises: []).}- @@ -394,9 +394,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit
Methods
method closeImpl(s: Connection): Future[void] {....raises: [], tags: [RootEffect].}
method closeImpl(s: Connection): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
proc closeWithEOF(s: LPStream): Future[void] {.public(), stackTrace: false, - ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, raises: [], - tags: [RootEffect].}
proc closeWithEOF(s: LPStream): InternalRaisesFuture[void, void] {.public(), + stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [RootEffect].}
Close the stream and wait for EOF - use this with half-closed streams where an EOF is expected to arrive from the other end.
@@ -634,9 +652,9 @@ class="link-seesrc" target="_blank">SourceIn particular, it must not be used when there is another concurrent read ongoing (which may be the case during cancellations)!
Source - Edit + Editproc readExactly(s: LPStream; pbytes: pointer; nbytes: int): Future[void] {. - public(), stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, - raises: [], tags: [RootEffect].}
proc readLine(s: LPStream; limit = 0; sep = "\r\n"): Future[string] {.public(), - stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, - raises: [], tags: [RootEffect].}
proc readLp(s: LPStream; maxSize: int): Future[seq[byte]] {.public(), - stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, - raises: [], tags: [RootEffect].}
proc readVarint(conn: LPStream): Future[uint64] {.public(), stackTrace: false, +
proc readExactly(s: LPStream; pbytes: pointer; nbytes: int): InternalRaisesFuture[ + void, (CancelledError, LPStreamError)] {.public(), stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, raises: [], tags: [RootEffect].}
proc readLine(s: LPStream; limit = 0; sep = "\r\n"): InternalRaisesFuture[ + string, (CancelledError, LPStreamError)] {.public(), stackTrace: false, + ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, raises: [], + tags: [RootEffect].}
proc readLp(s: LPStream; maxSize: int): InternalRaisesFuture[seq[byte], + (CancelledError, LPStreamError)] {.public(), stackTrace: false, ...raises: [], + gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [RootEffect].}
proc readVarint(conn: LPStream): InternalRaisesFuture[uint64, + (CancelledError, LPStreamError)] {.public(), stackTrace: false, ...raises: [], + gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [RootEffect].}
proc write(s: LPStream; msg: string): Future[void] {.public, ...gcsafe, raises: [], - tags: [].}
proc write(s: LPStream; msg: string): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.public(), stackTrace: false, ...raises: [], + gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [].}
proc writeLp(s: LPStream; msg: openArray[byte]): Future[void] {.public, ...gcsafe, - raises: [], tags: [].}
proc writeLp(s: LPStream; msg: openArray[byte]): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.public(), stackTrace: false, ...raises: [], + gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [].}
proc writeLp(s: LPStream; msg: string): Future[void] {.public, ...gcsafe, - raises: [], tags: [].}
proc writeLp(s: LPStream; msg: string): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.public(), stackTrace: false, ...raises: [], + gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [].}
method close(s: LPStream): Future[void] {.base, public(), stackTrace: false, - ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, raises: [], - tags: [RootEffect].}
method close(s: LPStream): InternalRaisesFuture[void, void] {.base, public(), + stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [].}
method closeImpl(s: LPStream): Future[void] {.base, stackTrace: false, - ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, raises: [], - tags: [RootEffect].}
method closeImpl(s: LPStream): InternalRaisesFuture[void, void] {.base, + stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, + raises: [], tags: [].}
method readOnce(s: LPStream; pbytes: pointer; nbytes: int): Future[int] {.base, - public(), stackTrace: false, ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, - raises: [], tags: [RootEffect].}
method readOnce(s: LPStream; pbytes: pointer; nbytes: int): InternalRaisesFuture[ + int, (CancelledError, LPStreamError)] {.base, public(), stackTrace: false, + ...raises: [], gcsafe, gcsafe, raises: [], gcsafe, raises: [], tags: [].}
method write(s: LPStream; msg: seq[byte]): Future[void] {.base, public, ...gcsafe, - raises: [], tags: [].}
method write(s: LPStream; msg: seq[byte]): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.base, public(), stackTrace: false, + ...raises: [], gcsafe, gcsafe, raises: [], + gcsafe, raises: [], tags: [].}
method closeImpl(s: WsStream): Future[void] {.stackTrace: false, ...raises: [], - gcsafe, raises: [], raises: [], tags: [RootEffect].}
method closeImpl(s: WsStream): InternalRaisesFuture[void, void] {. + stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], + tags: [RootEffect].}
method readOnce(s: WsStream; pbytes: pointer; nbytes: int): Future[int] {. - stackTrace: false, ...raises: [], gcsafe, raises: [], raises: [], - tags: [RootEffect].}
method readOnce(s: WsStream; pbytes: pointer; nbytes: int): InternalRaisesFuture[ + int, (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], + gcsafe, raises: [], raises: [], tags: [RootEffect].}
method write(s: WsStream; msg: seq[byte]): Future[void] {.stackTrace: false, - ...raises: [], gcsafe, raises: [], raises: [], tags: [RootEffect].}
method write(s: WsStream; msg: seq[byte]): InternalRaisesFuture[void, + (CancelledError, LPStreamError)] {.stackTrace: false, ...raises: [], gcsafe, + raises: [], raises: [], + tags: [RootEffect].}