diff --git a/zz-dbg/libp2p.html b/zz-dbg/libp2p.html index c7d94796c..802015c12 100644 --- a/zz-dbg/libp2p.html +++ b/zz-dbg/libp2p.html @@ -260,7 +260,7 @@ class="link-seesrc" target="_blank">Source
diff --git a/zz-dbg/libp2p/builders.html b/zz-dbg/libp2p/builders.html index 0324ff4d5..c85d4fe53 100644 --- a/zz-dbg/libp2p/builders.html +++ b/zz-dbg/libp2p/builders.html @@ -228,7 +228,8 @@ window.addEventListener("DOMContentLoaded", main2); autonat: bool circuitRelay: Relay rdv: RendezVous - services: seq[Service]">SwitchBuilder + services: seq[Service] + observedAddrManager: ObservedAddrManager">SwitchBuilderSet the listening address of the switch
Calling it multiple time will override the value
Set the listening addresses of the switch
Calling it multiple time will override the value
proc withObservedAddrManager(b: SwitchBuilder; + observedAddrManager: ObservedAddrManager): SwitchBuilder {. + ...raises: [], tags: [].}
proc getStream(c: ConnManager; peerId: PeerId): Future[Connection] {....gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + proc getStream(c: ConnManager; peerId: PeerId): Future[Connection] {. + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -719,8 +719,8 @@ class="link-seesrc" target="_blank">Source
proc getStream(c: ConnManager; peerId: PeerId; dir: Direction): Future[ - Connection] {....gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], - raises: [], tags: [RootEffect].}
proc triggerPeerEvents(c: ConnManager; peerId: PeerId; event: PeerEvent): Future[ - void] {....gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], - raises: [], tags: [RootEffect].}
method connect(self: Dial; peerId: PeerId; addrs: seq[MultiAddress]; - forceDial = false; reuseConnection = true; - upgradeDir = Direction.Out): Future[void] {.base, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], - tags: [RootEffect].}
method connect(self: Dialer; peerId: PeerId; addrs: seq[MultiAddress]; - forceDial = false; reuseConnection = true; - upgradeDir = Direction.Out): Future[void] {.stackTrace: false, - ...gcsafe, raises: [], tags: [RootEffect].}
This procedure performs validation of concatenated result and can raise exception on error.
Source - Edit + Edit @@ -2007,9 +2007,9 @@ class="link-seesrc" target="_blank">SourceThis procedure performs validation of concatenated result and can raise exception on error.
Source - Edit + Edit @@ -2020,9 +2020,9 @@ class="link-seesrc" target="_blank">Source Check of two MultiAddress are equal Source - Edit + Edit @@ -2033,9 +2033,9 @@ class="link-seesrc" target="_blank">Source Returns partial MultiAddress with MultiCodec codec and present in MultiAddress ma. Source - Edit + Edit @@ -2046,9 +2046,9 @@ class="link-seesrc" target="_blank">Source Returns part with index i of MultiAddress ma. Source - Edit + Edit @@ -2059,9 +2059,9 @@ class="link-seesrc" target="_blank">Source Returns parts with slice slice of MultiAddress ma. Source - Edit + Edit @@ -2072,9 +2072,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -2084,9 +2084,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -2097,9 +2097,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -2110,9 +2110,9 @@ class="link-seesrc" target="_blank">Source Returns true, if address with MultiCodec codec present in MultiAddress ma. Source - Edit + Edit @@ -2135,9 +2135,9 @@ class="link-seesrc" target="_blank">Source Get MultiBase encoded representation of ma using encoding encoding. Source - Edit + Edit @@ -2148,9 +2148,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -2162,9 +2162,9 @@ class="link-seesrc" target="_blank">Source Read repeated field from protobuf message. field is field number. If the message is malformed, an error is returned. If field is not present in message, then ok(false) is returned and value is empty. If field is present, but no items could be parsed, then err(ProtoError.IncorrectBlob) is returned and value is empty. If field is present and some item could be parsed, then true is returned and value contains the parsed values. Source - Edit + Edit @@ -2186,9 +2186,9 @@ class="link-seesrc" target="_blank">Source Return hexadecimal string representation of MultiAddress value. Source - Edit + Edit @@ -2198,9 +2198,23 @@ class="link-seesrc" target="_blank">Source Initialize empty MultiAddress. Source - Edit + Edit + + + +proc init(mtype: typedesc[MultiAddress]; address: IpAddress; + protocol: IpTransportProtocol; port: Port): MultiAddress {....raises: [], + public.}
proc init(mtype: typedesc[MultiAddress]; address: ValidIpAddress; - protocol: IpTransportProtocol; port: Port): MultiAddress {....raises: [], - public.}
If current MultiAddress do not have argument value, then result array will be empty.
Source - Edit + Edit @@ -2407,9 +2407,9 @@ class="link-seesrc" target="_blank">SourceIf current MultiAddress do not have argument value, then result array will be empty.
Source - Edit + Edit @@ -2422,9 +2422,9 @@ class="link-seesrc" target="_blank">SourceIf current MultiAddress do not have argument value, then result will be 0.
Source - Edit + Edit @@ -2435,9 +2435,9 @@ class="link-seesrc" target="_blank">Source Returns MultiAddress ma protocol code. Source - Edit + Edit @@ -2448,9 +2448,9 @@ class="link-seesrc" target="_blank">Source Returns list of protocol codecs inside of MultiAddress value. Source - Edit + Edit @@ -2461,9 +2461,9 @@ class="link-seesrc" target="_blank">Source Returns MultiAddress ma protocol name. Source - Edit + Edit @@ -2474,9 +2474,9 @@ class="link-seesrc" target="_blank">Source Return string representation of MultiAddress value. Source - Edit + Edit @@ -2486,9 +2486,9 @@ class="link-seesrc" target="_blank">Source Returns true if MultiAddress ma is valid. Source - Edit + Edit @@ -2499,9 +2499,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -2512,9 +2512,9 @@ class="link-seesrc" target="_blank">Source Write MultiAddress value ma to buffer vb. Source - Edit + Edit @@ -2530,9 +2530,9 @@ class="link-seesrc" target="_blank">Source Iterates over all addresses inside of MultiAddress ma. Source - Edit + Edit @@ -2551,7 +2551,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/multibase.html b/zz-dbg/libp2p/multibase.html index 69b6cad1e..0d02a861f 100644 --- a/zz-dbg/libp2p/multibase.html +++ b/zz-dbg/libp2p/multibase.html @@ -396,7 +396,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/multicodec.html b/zz-dbg/libp2p/multicodec.html index 2745cf8d1..d4f79ca55 100644 --- a/zz-dbg/libp2p/multicodec.html +++ b/zz-dbg/libp2p/multicodec.html @@ -297,9 +297,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -310,9 +310,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -327,9 +327,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -344,9 +344,9 @@ class="link-seesrc" target="_blank">Source Returns true if MultiCodecs a and b are not equal. Source - Edit + Edit @@ -356,9 +356,9 @@ class="link-seesrc" target="_blank">Source Returns string representation of MultiCodec mc. Source - Edit + Edit @@ -368,9 +368,9 @@ class="link-seesrc" target="_blank">Source Returns true if MultiCodecs a and b are equal. Source - Edit + Edit @@ -380,9 +380,9 @@ class="link-seesrc" target="_blank">Source Compares MultiCodec mc with integer code. Source - Edit + Edit @@ -392,9 +392,9 @@ class="link-seesrc" target="_blank">Source Compares MultiCodec mc with string name. Source - Edit + Edit @@ -404,9 +404,9 @@ class="link-seesrc" target="_blank">Source Return MultiCodec from integer representation code. If code is not valid multicodec code, then InvalidMultiCodec will be returned. Source - Edit + Edit @@ -417,9 +417,9 @@ class="link-seesrc" target="_blank">Source Return MultiCodec from string representation name. If name is not valid multicodec name, then InvalidMultiCodec will be returned. Source - Edit + Edit @@ -429,9 +429,9 @@ class="link-seesrc" target="_blank">Source Hash procedure for tables. Source - Edit + Edit @@ -441,9 +441,9 @@ class="link-seesrc" target="_blank">Source Generate MultiCodec from integer code at compile time. Source - Edit + Edit @@ -453,9 +453,9 @@ class="link-seesrc" target="_blank">Source Generate MultiCodec from string name at compile time. Source - Edit + Edit @@ -465,9 +465,9 @@ class="link-seesrc" target="_blank">Source Write MultiCodec to buffer vb. Source - Edit + Edit @@ -481,7 +481,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/multihash.html b/zz-dbg/libp2p/multihash.html index 2bbb8927f..9dfb99d74 100644 --- a/zz-dbg/libp2p/multihash.html +++ b/zz-dbg/libp2p/multihash.html @@ -689,7 +689,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/multistream.html b/zz-dbg/libp2p/multistream.html index 683c62314..8ac2fd002 100644 --- a/zz-dbg/libp2p/multistream.html +++ b/zz-dbg/libp2p/multistream.html @@ -376,9 +376,9 @@ class="link-seesrc" target="_blank">Source helper to allow registering pure handlers Source - Edit + Edit @@ -389,9 +389,9 @@ class="link-seesrc" target="_blank">Source Source - Edit + Edit @@ -402,16 +402,16 @@ class="link-seesrc" target="_blank">Source Source - Edit + Editproc handle(_: type MultistreamSelect; conn: Connection; protos: seq[string]; matchers = newSeq[Matcher](); active: bool = false): Future[string] {. - ...gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [].}
proc handle(m: MultistreamSelect; conn: Connection; active: bool = false): Future[ - void] {....gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], - raises: [], tags: [RootEffect].}
proc readMsg(conn: Connection): Future[Msg] {....gcsafe, stackTrace: false, ...gcsafe, + proc readMsg(conn: Connection): Future[Msg] {.stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -391,7 +391,7 @@ class="link-seesrc" target="_blank">Source
method close(m: Muxer): Future[void] {.base, ...gcsafe, stackTrace: false, ...gcsafe, + method close(m: Muxer): Future[void] {.base, stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -479,7 +479,7 @@ class="link-seesrc" target="_blank">Source
method handle(m: Muxer): Future[void] {.base, ...gcsafe, stackTrace: false, ...gcsafe, + method handle(m: Muxer): Future[void] {.base, stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -494,8 +494,8 @@ class="link-seesrc" target="_blank">Source
method newStream(m: Muxer; name: string = ""; lazy: bool = false): Future[ - Connection] {.base, ...gcsafe, stackTrace: false, ...gcsafe, raises: [], - raises: [], raises: [], tags: [RootEffect].}
YamuxDefaultWindowSize = 256000
proc new(T: type[Yamux]; conn: Connection; maxChannCount: int = MaxChannelCount): T:type {. - ...raises: [].}
proc new(T: type[Yamux]; conn: Connection; maxChannCount: int = MaxChannelCount; + windowSize: int = YamuxDefaultWindowSize; + maxSendQueueSize: int = MaxSendQueueSize): T:type {....raises: [].}
proc open(channel: YamuxChannel): Future[void] {....gcsafe, stackTrace: false, - ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
proc open(channel: YamuxChannel): Future[void] {.stackTrace: false, ...gcsafe, + raises: [], raises: [], raises: [], tags: [RootEffect].}
method closeImpl(channel: YamuxChannel): Future[void] {....gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], - tags: [RootEffect].}
method closeImpl(channel: YamuxChannel): Future[void] {.stackTrace: false, + ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
method handle(m: Yamux): Future[void] {....gcsafe, stackTrace: false, ...gcsafe, - raises: [], raises: [], raises: [], + method handle(m: Yamux): Future[void] {.stackTrace: false, ...gcsafe, raises: [], + raises: [], raises: [], tags: [RootEffect].}- Source - Edit + Edit
method newStream(m: Yamux; name: string = ""; lazy: bool = false): Future[ - Connection] {....gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], - raises: [], tags: [RootEffect].}
proc handleHop(r: Relay; connSrc: Connection; msg: RelayMessage): Future[void] {. - ...gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
proc handleHopStreamV2(r: Relay; conn: Connection): Future[void] {....gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + proc handleHopStreamV2(r: Relay; conn: Connection): Future[void] {. + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -567,7 +567,7 @@ class="link-seesrc" target="_blank">Source
proc dial(self: RelayTransport; ma: MultiAddress): Future[Connection] {....gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + proc dial(self: RelayTransport; ma: MultiAddress): Future[Connection] {. + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -337,9 +337,8 @@ class="link-seesrc" target="_blank">Source
Methods
-diff --git a/zz-dbg/libp2p/protocols/connectivity/relay/utils.html b/zz-dbg/libp2p/protocols/connectivity/relay/utils.html index ee1124576..27d9e4858 100644 --- a/zz-dbg/libp2p/protocols/connectivity/relay/utils.html +++ b/zz-dbg/libp2p/protocols/connectivity/relay/utils.html @@ -317,8 +317,8 @@ class="link-seesrc" target="_blank">Source- +
method accept(self: RelayTransport): Future[Connection] {....gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], - tags: [RootEffect].} method accept(self: RelayTransport): Future[Connection] {.stackTrace: false, + ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -353,7 +352,7 @@ class="link-seesrc" target="_blank">Source
method dial(self: RelayTransport; hostname: string; ma: MultiAddress; peerId: Opt[PeerId] = Opt.none(PeerId)): Future[Connection] {. - ...gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -393,8 +392,8 @@ class="link-seesrc" target="_blank">Source
-- +
method stop(self: RelayTransport): Future[void] {....gcsafe, stackTrace: false, - ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].} method stop(self: RelayTransport): Future[void] {.stackTrace: false, ...gcsafe, + raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -415,7 +414,7 @@ class="link-seesrc" target="_blank">Source
proc sendHopStatus(conn: Connection; code: StatusV2): Future[void] {....gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + proc sendHopStatus(conn: Connection; code: StatusV2): Future[void] {. + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -331,8 +331,8 @@ class="link-seesrc" target="_blank">Source
proc sendStatus(conn: Connection; code: StatusV1): Future[void] {....gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + proc sendStatus(conn: Connection; code: StatusV1): Future[void] {. + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -368,7 +368,7 @@ class="link-seesrc" target="_blank">Source
IdentifyPushCodec = "/ipfs/id/push/1.0.0"
ProtoVersion = "ipfs/0.1.0"
IdentifyPushCodec = "/ipfs/id/push/1.0.0"
ProtoVersion = "ipfs/0.1.0"
proc identify(self: Identify; conn: Connection; remotePeerId: PeerId): Future[ - IdentifyInfo] {....gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], + IdentifyInfo] {.stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
proc new(T: typedesc[Identify]; peerInfo: PeerInfo; sendSignedPeerRecord = false): T:type {. - ...raises: [].}
proc new(T: typedesc[Identify]; peerInfo: PeerInfo; + sendSignedPeerRecord = false; + observedAddrManager = ObservedAddrManager.new()): T:type {....raises: [].}
proc ping(p: Ping; conn: Connection): Future[Duration] {....gcsafe, public(), +
proc ping(p: Ping; conn: Connection): Future[Duration] {.public(), stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
proc rateLimit(g: GossipSub; peer: PubSubPeer; rpcMsgOpt: Opt[RPCMsg]; - msgSize: int): Future[void] {. - ...raises: [PeerRateLimitError, CatchableError], stackTrace: false, ...gcsafe, + msgSize: int): Future[void] {.stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
proc sendEncoded(p: PubSubPeer; msg: seq[byte]): Future[void] {....raises: [], - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + proc sendEncoded(p: PubSubPeer; msg: seq[byte]): Future[void] {. + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -721,7 +721,7 @@ class="link-seesrc" target="_blank">Source
Exports
-formatItIMPL, hash, shortLog, random, $, write, PeerId, ==, getField, <=, capLen, init, validate, init, match, <, getBytes, maxInlineKeyLength, write, withValue, safeConvert, shortLog, >=, withValue, public, shortLog, compilesOr, toBytes, match, valueOr, init, init, init, toOpt, init, hasPublicKey, >, hex, len, exceptionToAssert, cmp, extractPublicKey, newLPStreamWriteError, DNS_OR_IP, ProtoHeader, shortLog, init, random, UDP_DNS, $, <=, MaError, ephemeral, decode, MaPatternOp, ==, WS_DNS, initVBuffer, getProtoHeader, MaxSizeError, ProtoFlags, getLen, ECDHEScheme, shortLog, init, init, closed, [], macOpenArray, random, init, VBuffer, Secret, peekVarint, random, $, validate, mapOr, bytes, maxInlineKeyLength, TranscoderDNS, QUIC, [], key, ephemeral, withValue, getRequiredField, getField, writeLp, WS_IP, isEnough, public, MAKind, getBytes, write, DNSANY, checkFieldNumber, valueOr, getRepeatedField, matchPartial, libp2p_pki_schemes, getBytes, len, readVarint, readLp, HTTP, initVBuffer, mac, atEof, LPStreamTrackerName, peekSeq, toOpt, fullAddrs, payloadType, getProtoHeader, LPStreamError, IP, protoAddress, newRng, DefaultConnectionTimeout, ==, checkValid, getPublicKey, exceptionToAssert, decodeProposal, len, CircuitRelay, extractPublicKey, mapAnd, new, verify, UDP_IP, new, newLPStreamEOFError, init, write, ==, DNSADDR, AddressMapper, write, PeerId, WSS, LPStream, TCP_IP, close, hash, writePacked, init, closeImpl, readSeq, toBytes, TCP_DNS, shortLog, encode, len, capLen, protoName, toRawBytes, TranscoderIP6Zone, $, initProtoBuffer, newLPStreamReadError, init, WSS_DNS, match, writeLPVarint, CryptoResult, WebSockets_DNS, ProtoResult, WebRTCDirect, init, init, UDP, TranscoderOnion, StreamTracker, write, init, LPStreamResetError, isEmpty, writeArray, LPStreamReadError, decode, LPStreamIncompleteError, [], LPStreamEOFError, IP6, shortLog, initVBuffer, decode, PKScheme, payload, init, init, Connection, write, init, TCP, PrivateKey, getBytes, write, &=, PeerInfoError, newLPStreamClosedError, random, compilesOr, TranscoderIP4, init, initProtoBuffer, toException, DNS, UTP, goffset, readVarint, >, KeyPair, init, init, high, toString, cmp, init, SupportedWireTypes, formatItIMPL, formatItIMPL, formatItIMPL, Signature, contains, hash, formatItIMPL, toBytes, DigestSheme, init, IPFS, readOnce, init, isEmpty, ProtoScalar, shortLog, data, LPStreamIncorrectDefect, hex, protocols, update, HTTPS, tryAndWarn, WebSockets, LPError, getPtr, write, TLS_WS, sign, finish, encode, MaResult, ProtoField, init, toBytes, writeSeq, init, &, DNS6, IpTransportProtocol, toOpenArray, init, allFuturesThrowing, IP4, TranscoderPort, write, newLPStreamIncorrectDefect, getField, init, createExchange, >=, init, payloadDomain, $, MaPattern, withValue, getRawBytes, init, LPStreamLimitError, TranscoderOnion3, SignedPayload, toBytes, protoArgument, newLPStreamLimitError, keyOpenArray, match, createProposal, parseFullAddress, $, isEmpty, supported, getRequiredRepeatedField, init, newLPStreamIncompleteError, newLPStreamReadError, initProtoBuffer, MAProtocol, newLPStreamResetError, getPackedRepeatedField, initStream, init, getField, shortLog, DNS4, getWrapped, readArray, selectBest, safeConvert, P2PPattern, Envelope, hasPublicKey, toException, init, isEnough, init, Reliable, addrs, hex, ProtoBuffer, closeImpl, write, WS, stretchKeys, encode, init, init, getField, getField, match, getField, <, iv, readLine, Eof, CryptoError, getField, hash, append, vsizeof, init, parseFullAddress, WSS_IP, LPStreamConnDownError, peekArray, UNIX, PeerRecord, init, SupportedSchemes, getRepeatedField, LPStreamWriteError, getField, Unreliable, SupportedSchemesInt, random, checkFutures, shuffle, init, validate, $, protoCode, mapEq, Onion3, write, TcpOnion3, concat, TranscoderP2P, PeerInfo, AddressInfo, ConnectionTrackerName, TranscoderIP6, write, EnvelopeError, encode, newLPStreamRemoteClosedError, MaPatResult, Direction, InvalidVarintError, shortLog, items, ==, init, write, getBytes, write, init, PublicKey, WebSockets_IP, writeLp, writePBVarint, ProtoFieldKind, readExactly, protoArgument, getRepeatedField, ProtoError, newLPStreamConnDownError, write, initStream, getField, MultiAddress, finish, ivOpenArray, closeWithEOF, TimeoutHandler, orError, decodeExchange, getField, LPStreamRemoteClosedError, setupStreamTracker, MaInvalidAddress, LPStreamClosedError, RsaDefaultKeySize, write, getOrder, TranscoderUnix, SignedPeerRecord, join, writeVarint +formatItIMPL, hash, shortLog, random, $, write, PeerId, ==, getField, <=, capLen, init, validate, init, match, <, getBytes, maxInlineKeyLength, write, withValue, safeConvert, shortLog, >=, withValue, public, shortLog, compilesOr, toBytes, match, valueOr, init, init, init, toOpt, init, hasPublicKey, >, hex, len, exceptionToAssert, cmp, extractPublicKey, newLPStreamWriteError, DNS_OR_IP, ProtoHeader, shortLog, init, random, UDP_DNS, $, <=, MaError, ephemeral, decode, MaPatternOp, ==, WS_DNS, initVBuffer, getProtoHeader, MaxSizeError, ProtoFlags, getLen, ECDHEScheme, shortLog, init, init, closed, [], macOpenArray, random, init, VBuffer, Secret, peekVarint, random, $, validate, mapOr, bytes, maxInlineKeyLength, TranscoderDNS, QUIC, [], key, ephemeral, withValue, getRequiredField, getField, writeLp, WS_IP, isEnough, public, MAKind, getBytes, write, DNSANY, checkFieldNumber, valueOr, getRepeatedField, matchPartial, libp2p_pki_schemes, getBytes, len, readVarint, readLp, HTTP, initVBuffer, mac, atEof, LPStreamTrackerName, peekSeq, toOpt, fullAddrs, payloadType, getProtoHeader, LPStreamError, IP, protoAddress, newRng, DefaultConnectionTimeout, ==, checkValid, getPublicKey, exceptionToAssert, decodeProposal, len, CircuitRelay, extractPublicKey, mapAnd, new, verify, UDP_IP, new, newLPStreamEOFError, init, write, ==, DNSADDR, AddressMapper, write, PeerId, WSS, LPStream, TCP_IP, close, hash, writePacked, init, closeImpl, readSeq, toBytes, TCP_DNS, shortLog, encode, len, capLen, protoName, toRawBytes, TranscoderIP6Zone, $, initProtoBuffer, newLPStreamReadError, init, WSS_DNS, match, writeLPVarint, CryptoResult, WebSockets_DNS, ProtoResult, WebRTCDirect, init, init, UDP, TranscoderOnion, StreamTracker, write, init, LPStreamResetError, isEmpty, writeArray, LPStreamReadError, decode, LPStreamIncompleteError, [], LPStreamEOFError, IP6, shortLog, initVBuffer, decode, PKScheme, payload, init, init, Connection, write, init, TCP, PrivateKey, getBytes, write, &=, PeerInfoError, newLPStreamClosedError, random, compilesOr, TranscoderIP4, init, initProtoBuffer, toException, DNS, UTP, goffset, readVarint, >, KeyPair, init, init, high, toString, cmp, init, SupportedWireTypes, formatItIMPL, formatItIMPL, formatItIMPL, Signature, contains, hash, formatItIMPL, toBytes, DigestSheme, init, IPFS, readOnce, init, isEmpty, ProtoScalar, shortLog, data, LPStreamIncorrectDefect, hex, protocols, update, HTTPS, tryAndWarn, WebSockets, LPError, getPtr, write, TLS_WS, sign, finish, encode, MaResult, ProtoField, init, toBytes, writeSeq, init, &, DNS6, IpTransportProtocol, toOpenArray, init, allFuturesThrowing, IP4, TranscoderPort, write, newLPStreamIncorrectDefect, getField, init, createExchange, >=, init, payloadDomain, $, MaPattern, withValue, getRawBytes, init, LPStreamLimitError, TranscoderOnion3, SignedPayload, toBytes, protoArgument, newLPStreamLimitError, keyOpenArray, match, createProposal, parseFullAddress, $, isEmpty, supported, getRequiredRepeatedField, init, newLPStreamIncompleteError, newLPStreamReadError, initProtoBuffer, MAProtocol, newLPStreamResetError, getPackedRepeatedField, initStream, init, getField, shortLog, DNS4, getWrapped, readArray, selectBest, safeConvert, P2PPattern, Envelope, hasPublicKey, toException, init, isEnough, init, Reliable, addrs, hex, ProtoBuffer, closeImpl, write, WS, stretchKeys, encode, init, init, getField, getField, match, getField, <, iv, readLine, Eof, CryptoError, getField, hash, append, vsizeof, init, parseFullAddress, WSS_IP, LPStreamConnDownError, peekArray, UNIX, PeerRecord, init, SupportedSchemes, getRepeatedField, LPStreamWriteError, getField, Unreliable, SupportedSchemesInt, random, checkFutures, shuffle, init, validate, $, protoCode, mapEq, Onion3, write, TcpOnion3, concat, TranscoderP2P, PeerInfo, AddressInfo, ConnectionTrackerName, TranscoderIP6, write, EnvelopeError, encode, newLPStreamRemoteClosedError, MaPatResult, Direction, InvalidVarintError, shortLog, items, ==, init, write, getBytes, write, init, PublicKey, WebSockets_IP, writeLp, writePBVarint, ProtoFieldKind, readExactly, protoArgument, getRepeatedField, ProtoError, newLPStreamConnDownError, write, initStream, getField, MultiAddress, finish, ivOpenArray, closeWithEOF, TimeoutHandler, orError, decodeExchange, getField, LPStreamRemoteClosedError, setupStreamTracker, MaInvalidAddress, LPStreamClosedError, RsaDefaultKeySize, write, getOrder, TranscoderUnix, SignedPeerRecord, join, writeVarint
method secure(s: Secure; conn: Connection; initiator: bool; peerId: Opt[PeerId]): Future[ ++ method secure(s: Secure; conn: Connection; peerId: Opt[PeerId]): Future[ Connection] {.base, ...gcsafe, raises: [], tags: [RootEffect].}- @@ -549,7 +547,7 @@ class="link-seesrc" target="_blank">Source
proc readLp(s: LPStream; maxSize: int): Future[seq[byte]] {....gcsafe, public(), +
proc readLp(s: LPStream; maxSize: int): Future[seq[byte]] {.public(), stackTrace: false, ...gcsafe, raises: [], gcsafe, raises: [], gcsafe, raises: [], tags: [RootEffect].}
proc readVarint(conn: LPStream): Future[uint64] {....gcsafe, public(), - stackTrace: false, ...gcsafe, raises: [], gcsafe, raises: [], gcsafe, - raises: [], tags: [RootEffect].}
proc readVarint(conn: LPStream): Future[uint64] {.public(), stackTrace: false, + ...gcsafe, raises: [], gcsafe, raises: [], gcsafe, raises: [], + tags: [RootEffect].}
proc start(s: Switch): Future[void] {....gcsafe, public(), stackTrace: false, - ...gcsafe, raises: [], raises: [], - raises: [], tags: [RootEffect].}
proc start(s: Switch): Future[void] {.public(), stackTrace: false, ...gcsafe, + raises: [], raises: [], raises: [], + tags: [RootEffect].}
method connect(s: Switch; peerId: PeerId; addrs: seq[MultiAddress]; - forceDial = false; reuseConnection = true; - upgradeDir = Direction.Out): Future[void] {.public, ...raises: [], - tags: [RootEffect].}
method run(self: Service; switch: Switch): Future[void] {.base, ...gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + method run(self: Service; switch: Switch): Future[void] {.base, + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -709,8 +708,8 @@ class="link-seesrc" target="_blank">Source
method setup(self: Service; switch: Switch): Future[bool] {.base, ...gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + method setup(self: Service; switch: Switch): Future[bool] {.base, + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -723,8 +722,8 @@ class="link-seesrc" target="_blank">Source
method stop(self: Service; switch: Switch): Future[bool] {.base, ...gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + method stop(self: Service; switch: Switch): Future[bool] {.base, + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}- @@ -741,7 +740,7 @@ class="link-seesrc" target="_blank">Source
Exports
-ConnManager, getStream, PeerEventKind, getStream, addPeerEventHandler, new, ConnEventKind, PeerEventHandler, selectMuxer, getConnections, contains, removePeerEventHandler, expectConnection, ConnEvent, connCount, ConnEventHandler, addConnEventHandler, triggerConnEvent, removeConnEventHandler, contains, triggerPeerEvents, AlreadyExpectingConnectionError, PeerEvent, TooManyConnectionsError, getStream, trackConnection, close, MaxConnectionsPerPeer, connectedPeers, selectMuxer, trackMuxer, getOutgoingSlot, slotsAvailable, dropPeer, getIncomingSlot, storeMuxer, release, MaxConnections, ConnectionSlot, newLPStreamWriteError, DNS_OR_IP, AlreadyExpectingConnectionError, shortLog, init, random, new, UDP_DNS, $, getProtoHeader, MaxConnectionsPerPeer, ephemeral, close, MaPatternOp, WS_DNS, initVBuffer, <=, MaxSizeError, decodeProposal, ProtoFlags, ==, getLen, maxIncomingStreams, ECDHEScheme, shortLog, closed, addConnEventHandler, [], init, new, macOpenArray, random, init, new, Secret, peekVarint, random, handshake, MaxConnections, $, validate, mapOr, MaError, init, bytes, UpgradeFailedError, IdentityInvalidMsgError, maxInlineKeyLength, addHandler, TranscoderDNS, QUIC, ProtoVersion, [], init, ephemeral, withValue, getRequiredField, getField, init, writeLp, removeConnEventHandler, WS_IP, write, public, MAKind, decode, write, write, init, checkFieldNumber, valueOr, codec, getRepeatedField, matchPartial, addObservation, IdentityNoMatchError, libp2p_pki_schemes, push, getBytes, len, trackConnection, &, readLp, HTTP, initVBuffer, start, atEof, PeerEventKind, getOutgoingSlot, peekSeq, toOpt, fullAddrs, payloadType, getProtoHeader, LPStreamError, init, $, IP, protoAddress, newRng, ==, IdentifyPushCodec, SecureConn, checkValid, getPublicKey, CircuitRelay, ProtoHeader, WebSockets, libp2p_failed_upgrades_incoming, exceptionToAssert, extractPublicKey, mapAnd, new, UDP_IP, new, newLPStreamEOFError, selectMuxer, connCount, write, DNSADDR, LPError, AddressMapper, IdentifyPushHandler, write, ConnManager, WSS, getField, TCP_IP, selectMuxer, hash, writePacked, handle, init, closeImpl, Identify, toBytes, TCP_DNS, shortLog, encode, len, capLen, init, protoName, protoArgument, PeerEventHandler, LPProtoHandler, secure, toRawBytes, IdentifyPush, getStream, MaPattern, TranscoderIP6Zone, $, initProtoBuffer, newLPStreamReadError, WSS_DNS, list, match, <, CryptoResult, parseFullAddress, ProtoResult, WebRTCDirect, init, upgrade, UDP, TranscoderOnion, StreamTracker, IdentifyNoPubKeyError, write, init, LPStreamResetError, isEmpty, writeArray, writeLp, getRawBytes, new, LPStreamIncompleteError, PeerId, LPStreamEOFError, readOnce, maxIncomingStreams=, IP6, shortLog, new, release, initVBuffer, PKScheme, new, payload, triggerConnEvent, triggerPeerEvents, stretchKeys, init, Connection, write, TCP, PrivateKey, dropPeer, getBytes, start, newLPStreamIncorrectDefect, init, close, &=, PeerInfoError, newLPStreamClosedError, random, compilesOr, handle, trackMuxer, init, initProtoBuffer, toException, DNS, Upgrade, goffset, HandlerHolder, >, SecureConnTrackerName, KeyPair, init, high, toString, cmp, init, SupportedWireTypes, formatItIMPL, formatItIMPL, initStream, hash, formatItIMPL, Signature, formatItIMPL, getStream, IPFS, shortLog, readOnce, init, init, secure, isEmpty, ConnEventKind, MultiAddress, ProtoScalar, shortLog, LPStreamIncorrectDefect, contains, hex, expandItIMPL, protocols, codec=, init, DefaultMaxIncomingStreams, HTTPS, UNIX, encode, tryAndWarn, TooManyConnectionsError, ConnectionSlot, getPtr, write, TLS_WS, sign, readSeq, addHandler, storeMuxer, TranscoderIP4, formatItIMPL, PeerEvent, supported, MaResult, init, ProtoField, write, getStream, writeSeq, DigestSheme, ConnEvent, ==, $, DNS6, [], IpTransportProtocol, toOpenArray, init, allFuturesThrowing, IP4, TranscoderPort, isEnough, safeConvert, addPeerEventHandler, init, createExchange, >=, expectConnection, init, payloadDomain, $, withValue, init, init, LPStreamLimitError, TranscoderOnion3, SignedPayload, closeImpl, toBytes, Secure, newLPStreamLimitError, keyOpenArray, init, match, WebSockets_DNS, $, closeImpl, isEmpty, LPStreamReadError, decode, connectedPeers, mac, new, getRequiredRepeatedField, init, newLPStreamIncompleteError, newLPStreamReadError, initProtoBuffer, MAProtocol, newLPStreamResetError, getPackedRepeatedField, initStream, contains, getField, shortLog, DNS4, getWrapped, readArray, selectBest, write, P2PPattern, getWrapped, Envelope, hasPublicKey, toException, contains, decode, init, isEnough, init, Reliable, init, addrs, hex, slotsAvailable, data, readMessage, WS, AgentVersion, init, init, MultistreamSelect, encode, LPProtocol, DNSANY, TimeoutHandler, getField, match, getField, writeLPVarint, iv, DefaultConnectionTimeout, readLine, Eof, CryptoError, getField, append, init, parseFullAddress, WSS_IP, LPStreamConnDownError, PeerRecord, decodeExchange, SupportedSchemes, getRepeatedField, LPStreamWriteError, getField, select, hash, Unreliable, SupportedSchemesInt, random, checkFutures, libp2p_failed_upgrades_outgoing, shuffle, init, validate, Matcher, mapEq, getField, readVarint, removePeerEventHandler, Onion3, getBytes, LPStreamTrackerName, identify, select, concat, TranscoderP2P, PeerInfo, AddressInfo, ConnectionTrackerName, TranscoderIP6, finish, write, EnvelopeError, verify, IdentifyInfo, IdentifyError, addHandler, encode, len, newLPStreamRemoteClosedError, createProposal, MaPatResult, Direction, ProtoBuffer, IdentifyCodec, key, InvalidVarintError, shortLog, ==, init, write, getBytes, write, init, UTP, getConnections, toBytes, peekArray, init, getMostObservedProtosAndPorts, ObservedAddrManager, PublicKey, ConnEventHandler, WebSockets_IP, decodeMsg, VBuffer, update, writePBVarint, ProtoFieldKind, readExactly, protoArgument, getRepeatedField, ProtoError, newLPStreamConnDownError, init, write, initStream, getField, readVarint, ivOpenArray, closeWithEOF, finish, TcpOnion3, orError, vsizeof, getField, LPStreamRemoteClosedError, setupStreamTracker, guessDialableAddr, MultiStreamError, protoCode, stop, MaInvalidAddress, select, LPStream, LPStreamClosedError, RsaDefaultKeySize, writeVarint, getIncomingSlot, items, write, toBytes, getOrder, TranscoderUnix, SignedPeerRecord, init, stop, join, dial, dial, dial, connect, checkFutures, tryAndWarn, LPError, addTransport, addTransport, connect, toException, new, dial, allFuturesThrowing, Dialer, tryDial, DialFailedError, connect, Dial, connect, toException, tryDial, SPRBook, PeerBook, ProtoBook, AddressBook, ProtoVersionBook, SeqPeerBook, KeyBook, PeerBookChangeHandler, AgentBook, new, PeerStore +ConnManager, getStream, PeerEventKind, getStream, addPeerEventHandler, new, ConnEventKind, PeerEventHandler, selectMuxer, getConnections, contains, removePeerEventHandler, expectConnection, ConnEvent, connCount, ConnEventHandler, addConnEventHandler, triggerConnEvent, removeConnEventHandler, contains, triggerPeerEvents, AlreadyExpectingConnectionError, PeerEvent, TooManyConnectionsError, getStream, trackConnection, close, MaxConnectionsPerPeer, connectedPeers, selectMuxer, trackMuxer, getOutgoingSlot, slotsAvailable, dropPeer, getIncomingSlot, storeMuxer, release, MaxConnections, ConnectionSlot, newLPStreamWriteError, DNS_OR_IP, AlreadyExpectingConnectionError, shortLog, init, random, new, UDP_DNS, $, getProtoHeader, MaxConnectionsPerPeer, ephemeral, close, MaPatternOp, WS_DNS, initVBuffer, <=, MaxSizeError, decodeProposal, ProtoFlags, ==, getLen, maxIncomingStreams, ECDHEScheme, shortLog, closed, addConnEventHandler, [], init, new, macOpenArray, random, init, new, Secret, peekVarint, random, handshake, MaxConnections, $, validate, mapOr, MaError, init, bytes, UpgradeFailedError, IdentityInvalidMsgError, maxInlineKeyLength, addHandler, TranscoderDNS, QUIC, ProtoVersion, [], init, ephemeral, withValue, getRequiredField, getField, init, writeLp, removeConnEventHandler, WS_IP, write, public, MAKind, decode, write, write, init, checkFieldNumber, valueOr, codec, getRepeatedField, matchPartial, addObservation, IdentityNoMatchError, libp2p_pki_schemes, push, getBytes, len, trackConnection, &, readLp, HTTP, initVBuffer, start, atEof, PeerEventKind, getOutgoingSlot, peekSeq, toOpt, fullAddrs, payloadType, getProtoHeader, LPStreamError, init, $, IP, protoAddress, newRng, ==, IdentifyPushCodec, SecureConn, checkValid, getPublicKey, CircuitRelay, ProtoHeader, WebSockets, libp2p_failed_upgrades_incoming, exceptionToAssert, extractPublicKey, mapAnd, new, UDP_IP, new, newLPStreamEOFError, selectMuxer, connCount, write, DNSADDR, LPError, AddressMapper, IdentifyPushHandler, write, ConnManager, WSS, getField, TCP_IP, selectMuxer, hash, writePacked, handle, init, closeImpl, Identify, toBytes, TCP_DNS, shortLog, encode, len, capLen, init, protoName, protoArgument, PeerEventHandler, LPProtoHandler, secure, toRawBytes, IdentifyPush, getStream, MaPattern, TranscoderIP6Zone, $, initProtoBuffer, newLPStreamReadError, WSS_DNS, list, match, <, CryptoResult, parseFullAddress, ProtoResult, WebRTCDirect, init, upgrade, UDP, TranscoderOnion, StreamTracker, IdentifyNoPubKeyError, write, init, LPStreamResetError, isEmpty, writeArray, writeLp, getRawBytes, new, LPStreamIncompleteError, PeerId, LPStreamEOFError, readOnce, maxIncomingStreams=, IP6, shortLog, new, release, initVBuffer, PKScheme, new, payload, triggerConnEvent, triggerPeerEvents, stretchKeys, init, Connection, write, TCP, PrivateKey, dropPeer, getBytes, start, newLPStreamIncorrectDefect, init, close, &=, PeerInfoError, newLPStreamClosedError, random, compilesOr, handle, trackMuxer, init, initProtoBuffer, toException, DNS, Upgrade, goffset, HandlerHolder, >, SecureConnTrackerName, KeyPair, init, high, toString, cmp, init, SupportedWireTypes, formatItIMPL, formatItIMPL, initStream, hash, formatItIMPL, Signature, formatItIMPL, getStream, IPFS, shortLog, readOnce, init, init, secure, isEmpty, ConnEventKind, MultiAddress, ProtoScalar, shortLog, LPStreamIncorrectDefect, contains, hex, expandItIMPL, protocols, codec=, init, DefaultMaxIncomingStreams, HTTPS, UNIX, encode, tryAndWarn, TooManyConnectionsError, ConnectionSlot, getPtr, write, TLS_WS, sign, readSeq, addHandler, storeMuxer, TranscoderIP4, formatItIMPL, PeerEvent, supported, MaResult, init, ProtoField, write, getStream, writeSeq, DigestSheme, ConnEvent, ==, $, DNS6, [], IpTransportProtocol, toOpenArray, init, allFuturesThrowing, IP4, TranscoderPort, isEnough, safeConvert, addPeerEventHandler, init, createExchange, >=, expectConnection, init, payloadDomain, $, withValue, init, init, LPStreamLimitError, TranscoderOnion3, SignedPayload, closeImpl, toBytes, Secure, newLPStreamLimitError, keyOpenArray, init, match, WebSockets_DNS, $, closeImpl, isEmpty, LPStreamReadError, decode, connectedPeers, mac, new, getRequiredRepeatedField, init, newLPStreamIncompleteError, newLPStreamReadError, initProtoBuffer, MAProtocol, newLPStreamResetError, getPackedRepeatedField, initStream, contains, getField, shortLog, DNS4, getWrapped, readArray, selectBest, write, P2PPattern, getWrapped, Envelope, hasPublicKey, toException, contains, decode, init, isEnough, init, Reliable, init, addrs, hex, slotsAvailable, data, readMessage, WS, AgentVersion, init, init, MultistreamSelect, encode, LPProtocol, DNSANY, TimeoutHandler, getField, match, getField, writeLPVarint, iv, DefaultConnectionTimeout, readLine, Eof, CryptoError, getField, append, init, parseFullAddress, WSS_IP, LPStreamConnDownError, PeerRecord, decodeExchange, SupportedSchemes, getRepeatedField, LPStreamWriteError, getField, select, hash, Unreliable, SupportedSchemesInt, random, checkFutures, libp2p_failed_upgrades_outgoing, shuffle, init, validate, Matcher, mapEq, getField, readVarint, removePeerEventHandler, Onion3, getBytes, LPStreamTrackerName, identify, select, concat, TranscoderP2P, PeerInfo, AddressInfo, ConnectionTrackerName, TranscoderIP6, finish, write, EnvelopeError, verify, IdentifyInfo, IdentifyError, addHandler, encode, len, newLPStreamRemoteClosedError, createProposal, MaPatResult, Direction, ProtoBuffer, IdentifyCodec, key, InvalidVarintError, shortLog, ==, init, write, getBytes, write, init, UTP, getConnections, toBytes, peekArray, init, getMostObservedProtosAndPorts, ObservedAddrManager, PublicKey, ConnEventHandler, WebSockets_IP, decodeMsg, VBuffer, update, writePBVarint, ProtoFieldKind, readExactly, protoArgument, getRepeatedField, ProtoError, newLPStreamConnDownError, init, write, initStream, getField, readVarint, ivOpenArray, closeWithEOF, finish, TcpOnion3, orError, vsizeof, getField, LPStreamRemoteClosedError, setupStreamTracker, guessDialableAddr, MultiStreamError, protoCode, stop, MaInvalidAddress, select, LPStream, LPStreamClosedError, RsaDefaultKeySize, writeVarint, getIncomingSlot, items, write, toBytes, getOrder, TranscoderUnix, SignedPeerRecord, init, stop, join, dial, dial, dial, connect, checkFutures, tryAndWarn, LPError, addTransport, addTransport, connect, toException, new, dial, allFuturesThrowing, Dialer, tryDial, DialFailedError, connect, Dial, connect, toException, tryDial, SPRBook, PeerBook, ProtoBook, AddressBook, ProtoVersionBook, SeqPeerBook, KeyBook, PeerBookChangeHandler, AgentBook, new, PeerStore
method dial(self: TcpTransport; hostname: string; address: MultiAddress; peerId: Opt[PeerId] = Opt.none(PeerId)): Future[Connection] {. - ...gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
method stop(self: TcpTransport): Future[void] {....gcsafe, stackTrace: false, - ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
method stop(self: TcpTransport): Future[void] {.stackTrace: false, ...gcsafe, + raises: [], raises: [], raises: [], tags: [RootEffect].}
method upgrade(self: Transport; conn: Connection; direction: Direction; - peerId: Opt[PeerId]): Future[Muxer] {.base, ...gcsafe, raises: [], - tags: [].}
method upgrade(self: Transport; conn: Connection; peerId: Opt[PeerId]): Future[ + Muxer] {.base, ...gcsafe, raises: [], tags: [].}
method accept(self: WsTransport): Future[Connection] {....gcsafe, - stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], - tags: [RootEffect].}
method accept(self: WsTransport): Future[Connection] {.stackTrace: false, + ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
method stop(self: WsTransport): Future[void] {....gcsafe, stackTrace: false, - ...gcsafe, raises: [], raises: [], raises: [], tags: [RootEffect].}
method stop(self: WsTransport): Future[void] {.stackTrace: false, ...gcsafe, + raises: [], raises: [], raises: [], tags: [RootEffect].}
proc mux(self: MuxedUpgrade; conn: Connection; direction: Direction): Future[ - Muxer] {....gcsafe, stackTrace: false, ...gcsafe, raises: [], raises: [], - raises: [], tags: [RootEffect].}
proc mux(self: MuxedUpgrade; conn: Connection): Future[Muxer] {. + stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + tags: [RootEffect].}
method upgrade(self: MuxedUpgrade; conn: Connection; direction: Direction; - peerId: Opt[PeerId]): Future[Muxer] {.stackTrace: false, ...gcsafe, - raises: [], raises: [], raises: [], tags: [RootEffect].}
method upgrade(self: MuxedUpgrade; conn: Connection; peerId: Opt[PeerId]): Future[ + Muxer] {.stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [], + tags: [RootEffect].}
proc secure(self: Upgrade; conn: Connection; direction: Direction; - peerId: Opt[PeerId]): Future[Connection] {....gcsafe, - stackTrace: false, ...gcsafe, raises: [], gcsafe, raises: [], gcsafe, - raises: [], tags: [RootEffect].}
proc secure(self: Upgrade; conn: Connection; peerId: Opt[PeerId]): Future[ + Connection] {.stackTrace: false, ...gcsafe, raises: [], gcsafe, raises: [], + gcsafe, raises: [], tags: [RootEffect].}
method upgrade(self: Upgrade; conn: Connection; direction: Direction; - peerId: Opt[PeerId]): Future[Muxer] {.base, ...gcsafe, raises: [], - tags: [].}
method upgrade(self: Upgrade; conn: Connection; peerId: Opt[PeerId]): Future[ + Muxer] {.base, ...gcsafe, raises: [], tags: [].}
template withValue[T](self: Opt[T] | Option[T]; value, body: untyped): untyped
This template provides a convenient way to work with Option types in Nim. It allows you to execute a block of code (body) only when the Option is not empty.
+self is the Option instance being checked. value is the variable name to be used within the body for the unwrapped value. body is a block of code that is executed only if self contains a value.
+The value within body is automatically unwrapped from the Option, making it simpler to work with without needing explicit checks or unwrapping.
+Example:
+let myOpt = Opt.some(5) +myOpt.withValue(value): + echo value # Will print 5 ++
Note: This is a template, and it will be inlined at the call site, offering good performance.
Source diff --git a/zz-dbg/libp2p/utils/future.html b/zz-dbg/libp2p/utils/future.html index 6a968b93b..5548ad90a 100644 --- a/zz-dbg/libp2p/utils/future.html +++ b/zz-dbg/libp2p/utils/future.html @@ -271,7 +271,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/utils/heartbeat.html b/zz-dbg/libp2p/utils/heartbeat.html index 0de52c2e2..046d02de3 100644 --- a/zz-dbg/libp2p/utils/heartbeat.html +++ b/zz-dbg/libp2p/utils/heartbeat.html @@ -245,7 +245,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/utils/offsettedseq.html b/zz-dbg/libp2p/utils/offsettedseq.html index 698f07d52..2791940f7 100644 --- a/zz-dbg/libp2p/utils/offsettedseq.html +++ b/zz-dbg/libp2p/utils/offsettedseq.html @@ -512,7 +512,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/utils/semaphore.html b/zz-dbg/libp2p/utils/semaphore.html index 3c07aa75d..b7d5ff506 100644 --- a/zz-dbg/libp2p/utils/semaphore.html +++ b/zz-dbg/libp2p/utils/semaphore.html @@ -362,7 +362,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/varint.html b/zz-dbg/libp2p/varint.html index 6ebcbf50d..40ac4ba1c 100644 --- a/zz-dbg/libp2p/varint.html +++ b/zz-dbg/libp2p/varint.html @@ -725,7 +725,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/vbuffer.html b/zz-dbg/libp2p/vbuffer.html index 653c9d6b4..0e48dd13f 100644 --- a/zz-dbg/libp2p/vbuffer.html +++ b/zz-dbg/libp2p/vbuffer.html @@ -636,7 +636,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/libp2p/wire.html b/zz-dbg/libp2p/wire.html index 2ad2e978e..8880555c4 100644 --- a/zz-dbg/libp2p/wire.html +++ b/zz-dbg/libp2p/wire.html @@ -604,7 +604,7 @@ class="link-seesrc" target="_blank">Source diff --git a/zz-dbg/theindex.html b/zz-dbg/theindex.html index d998bbcfe..b7940db82 100644 --- a/zz-dbg/theindex.html +++ b/zz-dbg/theindex.html @@ -746,17 +746,17 @@ window.addEventListener('DOMContentLoaded', main); PeerId]