From c874aed2919b41e25fd0f8fae57772932ad52cd4 Mon Sep 17 00:00:00 2001 From: = Date: Fri, 16 Feb 2024 09:56:19 +0000 Subject: [PATCH] update docs for unstable --- unstable/libp2p.html | 2 +- unstable/libp2p/builders.html | 2 +- unstable/libp2p/connmanager.html | 2 +- unstable/libp2p/crypto/chacha20poly1305.html | 2 +- unstable/libp2p/crypto/crypto.html | 2 +- unstable/libp2p/crypto/curve25519.html | 2 +- unstable/libp2p/crypto/ecnist.html | 2 +- unstable/libp2p/crypto/ed25519/constants.html | 2 +- unstable/libp2p/crypto/ed25519/ed25519.html | 2 +- unstable/libp2p/crypto/hkdf.html | 2 +- unstable/libp2p/crypto/minasn1.html | 2 +- unstable/libp2p/crypto/rsa.html | 2 +- unstable/libp2p/crypto/secp.html | 2 +- unstable/libp2p/dial.html | 2 +- unstable/libp2p/dialer.html | 2 +- unstable/libp2p/errors.html | 2 +- unstable/libp2p/multiaddress.html | 2 +- unstable/libp2p/multibase.html | 2 +- unstable/libp2p/multicodec.html | 2 +- unstable/libp2p/multihash.html | 2 +- unstable/libp2p/multistream.html | 2 +- unstable/libp2p/muxers/mplex/coder.html | 2 +- unstable/libp2p/muxers/mplex/mplex.html | 2 +- unstable/libp2p/muxers/muxer.html | 2 +- unstable/libp2p/muxers/yamux/yamux.html | 2 +- .../libp2p/nameresolving/nameresolver.html | 2 +- unstable/libp2p/observedaddrmanager.html | 2 +- unstable/libp2p/peerid.html | 2 +- unstable/libp2p/peerinfo.html | 2 +- unstable/libp2p/protobuf/minprotobuf.html | 2 +- .../protocols/connectivity/autonat/core.html | 2 +- .../connectivity/autonat/server.html | 2 +- .../protocols/connectivity/relay/client.html | 2 +- .../connectivity/relay/messages.html | 2 +- .../protocols/connectivity/relay/rconn.html | 2 +- .../protocols/connectivity/relay/relay.html | 2 +- .../connectivity/relay/rtransport.html | 2 +- .../protocols/connectivity/relay/utils.html | 2 +- unstable/libp2p/protocols/identify.html | 2 +- unstable/libp2p/protocols/ping.html | 2 +- unstable/libp2p/protocols/protocol.html | 2 +- unstable/libp2p/protocols/pubsub.html | 4 +- unstable/libp2p/protocols/pubsub/errors.html | 2 +- .../libp2p/protocols/pubsub/floodsub.html | 2 +- .../libp2p/protocols/pubsub/gossipsub.html | 46 ++--- .../protocols/pubsub/gossipsub/behavior.html | 2 +- .../protocols/pubsub/gossipsub/scoring.html | 2 +- .../protocols/pubsub/gossipsub/types.html | 2 +- unstable/libp2p/protocols/pubsub/mcache.html | 2 +- .../libp2p/protocols/pubsub/peertable.html | 2 +- unstable/libp2p/protocols/pubsub/pubsub.html | 129 ++++++------ .../libp2p/protocols/pubsub/pubsubpeer.html | 185 ++++++++++++------ .../libp2p/protocols/pubsub/rpc/message.html | 2 +- .../libp2p/protocols/pubsub/rpc/messages.html | 2 +- .../libp2p/protocols/pubsub/rpc/protobuf.html | 2 +- .../libp2p/protocols/pubsub/timedcache.html | 2 +- unstable/libp2p/protocols/rendezvous.html | 2 +- unstable/libp2p/protocols/secure/noise.html | 2 +- unstable/libp2p/protocols/secure/secure.html | 2 +- unstable/libp2p/routing_record.html | 2 +- unstable/libp2p/signed_envelope.html | 2 +- unstable/libp2p/stream/bufferstream.html | 2 +- unstable/libp2p/stream/chronosstream.html | 2 +- unstable/libp2p/stream/connection.html | 2 +- unstable/libp2p/stream/lpstream.html | 2 +- unstable/libp2p/stream/streamseq.html | 2 +- unstable/libp2p/switch.html | 2 +- unstable/libp2p/transcoder.html | 2 +- unstable/libp2p/transports/tcptransport.html | 2 +- unstable/libp2p/transports/transport.html | 2 +- unstable/libp2p/transports/wstransport.html | 2 +- .../libp2p/upgrademngrs/muxedupgrade.html | 2 +- unstable/libp2p/upgrademngrs/upgrade.html | 2 +- unstable/libp2p/utility.html | 2 +- unstable/libp2p/utils/future.html | 2 +- unstable/libp2p/utils/heartbeat.html | 2 +- unstable/libp2p/utils/offsettedseq.html | 2 +- unstable/libp2p/utils/semaphore.html | 2 +- unstable/libp2p/varint.html | 2 +- unstable/libp2p/vbuffer.html | 2 +- unstable/libp2p/wire.html | 2 +- unstable/theindex.html | 20 +- 82 files changed, 312 insertions(+), 226 deletions(-) diff --git a/unstable/libp2p.html b/unstable/libp2p.html index 2e61f0a87..0ac86fc72 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 6f6e46a6c..9d84ffdc8 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 20ebc02f8..913f5f1e8 100644 --- a/unstable/libp2p/connmanager.html +++ b/unstable/libp2p/connmanager.html @@ -857,7 +857,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/crypto/chacha20poly1305.html b/unstable/libp2p/crypto/chacha20poly1305.html index b0d7f320d..cce5e63cd 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 dff0e5c31..91edc38e3 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 57cad7f5d..6ffb6e196 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 e84be06f4..7d19d1558 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 476c132b1..9da5994c1 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 03cd722c8..bd90419ae 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 dddefc368..de9d7b5b5 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 8eddaa867..154e019b0 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 3145f8a7e..06d1a550d 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 cf0b5285b..b8c160175 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 7dab01a70..a5f8f0d8d 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 80aeb0e11..121f32147 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 2c63e34ae..b8bd4eb38 100644 --- a/unstable/libp2p/errors.html +++ b/unstable/libp2p/errors.html @@ -357,7 +357,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/multiaddress.html b/unstable/libp2p/multiaddress.html index 9875d40ab..1d388b6e7 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 ba89d8930..a84094989 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 1d5784e96..4a18462e6 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 a271c6880..ffedba6ac 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 5ed8a4efa..39ca940ee 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 732e1df2e..78dac92da 100644 --- a/unstable/libp2p/muxers/mplex/coder.html +++ b/unstable/libp2p/muxers/mplex/coder.html @@ -391,7 +391,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/muxers/mplex/mplex.html b/unstable/libp2p/muxers/mplex/mplex.html index ec44b42a2..5e754495d 100644 --- a/unstable/libp2p/muxers/mplex/mplex.html +++ b/unstable/libp2p/muxers/mplex/mplex.html @@ -415,7 +415,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/muxers/muxer.html b/unstable/libp2p/muxers/muxer.html index d151f4670..ae29553e2 100644 --- a/unstable/libp2p/muxers/muxer.html +++ b/unstable/libp2p/muxers/muxer.html @@ -533,7 +533,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/muxers/yamux/yamux.html b/unstable/libp2p/muxers/yamux/yamux.html index 657fede1c..aed8c9c52 100644 --- a/unstable/libp2p/muxers/yamux/yamux.html +++ b/unstable/libp2p/muxers/yamux/yamux.html @@ -590,7 +590,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/nameresolving/nameresolver.html b/unstable/libp2p/nameresolving/nameresolver.html index 1831963e8..40a13f32d 100644 --- a/unstable/libp2p/nameresolving/nameresolver.html +++ b/unstable/libp2p/nameresolving/nameresolver.html @@ -375,7 +375,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/observedaddrmanager.html b/unstable/libp2p/observedaddrmanager.html index 841db07da..a0f013e71 100644 --- a/unstable/libp2p/observedaddrmanager.html +++ b/unstable/libp2p/observedaddrmanager.html @@ -360,7 +360,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/peerid.html b/unstable/libp2p/peerid.html index 18bd0be95..57dbc9fc0 100644 --- a/unstable/libp2p/peerid.html +++ b/unstable/libp2p/peerid.html @@ -806,7 +806,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/peerinfo.html b/unstable/libp2p/peerinfo.html index c63323a45..b3917081f 100644 --- a/unstable/libp2p/peerinfo.html +++ b/unstable/libp2p/peerinfo.html @@ -484,7 +484,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protobuf/minprotobuf.html b/unstable/libp2p/protobuf/minprotobuf.html index da81856a2..7cc9e836a 100644 --- a/unstable/libp2p/protobuf/minprotobuf.html +++ b/unstable/libp2p/protobuf/minprotobuf.html @@ -931,7 +931,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/connectivity/autonat/core.html b/unstable/libp2p/protocols/connectivity/autonat/core.html index fc1c49855..07430e517 100644 --- a/unstable/libp2p/protocols/connectivity/autonat/core.html +++ b/unstable/libp2p/protocols/connectivity/autonat/core.html @@ -508,7 +508,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/connectivity/autonat/server.html b/unstable/libp2p/protocols/connectivity/autonat/server.html index 279e78392..e02c418ef 100644 --- a/unstable/libp2p/protocols/connectivity/autonat/server.html +++ b/unstable/libp2p/protocols/connectivity/autonat/server.html @@ -302,7 +302,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/connectivity/relay/client.html b/unstable/libp2p/protocols/connectivity/relay/client.html index 9a306d6ce..e9cedd984 100644 --- a/unstable/libp2p/protocols/connectivity/relay/client.html +++ b/unstable/libp2p/protocols/connectivity/relay/client.html @@ -468,7 +468,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/connectivity/relay/messages.html b/unstable/libp2p/protocols/connectivity/relay/messages.html index 16b03242d..b4781dd51 100644 --- a/unstable/libp2p/protocols/connectivity/relay/messages.html +++ b/unstable/libp2p/protocols/connectivity/relay/messages.html @@ -722,7 +722,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/connectivity/relay/rconn.html b/unstable/libp2p/protocols/connectivity/relay/rconn.html index 141fc8e47..bb0ea4aad 100644 --- a/unstable/libp2p/protocols/connectivity/relay/rconn.html +++ b/unstable/libp2p/protocols/connectivity/relay/rconn.html @@ -377,7 +377,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/connectivity/relay/relay.html b/unstable/libp2p/protocols/connectivity/relay/relay.html index 50eb1ec16..ef538d9cb 100644 --- a/unstable/libp2p/protocols/connectivity/relay/relay.html +++ b/unstable/libp2p/protocols/connectivity/relay/relay.html @@ -567,7 +567,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/connectivity/relay/rtransport.html b/unstable/libp2p/protocols/connectivity/relay/rtransport.html index ee3aa31a7..15ead2c48 100644 --- a/unstable/libp2p/protocols/connectivity/relay/rtransport.html +++ b/unstable/libp2p/protocols/connectivity/relay/rtransport.html @@ -414,7 +414,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/connectivity/relay/utils.html b/unstable/libp2p/protocols/connectivity/relay/utils.html index 050d77fde..e1c0b86c3 100644 --- a/unstable/libp2p/protocols/connectivity/relay/utils.html +++ b/unstable/libp2p/protocols/connectivity/relay/utils.html @@ -368,7 +368,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/identify.html b/unstable/libp2p/protocols/identify.html index 887bbfed4..7ee414a1c 100644 --- a/unstable/libp2p/protocols/identify.html +++ b/unstable/libp2p/protocols/identify.html @@ -636,7 +636,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/ping.html b/unstable/libp2p/protocols/ping.html index de1968d21..9fe4a9b39 100644 --- a/unstable/libp2p/protocols/ping.html +++ b/unstable/libp2p/protocols/ping.html @@ -414,7 +414,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/protocol.html b/unstable/libp2p/protocols/protocol.html index 2e02f2238..327c34f3c 100644 --- a/unstable/libp2p/protocols/protocol.html +++ b/unstable/libp2p/protocols/protocol.html @@ -467,7 +467,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub.html b/unstable/libp2p/protocols/pubsub.html index 6327528f5..bd30d37a1 100644 --- a/unstable/libp2p/protocols/pubsub.html +++ b/unstable/libp2p/protocols/pubsub.html @@ -229,7 +229,7 @@ class="link-seesrc" target="_blank">Source

Exports

-maxIncomingStreams=, codec=, libp2p_pubsub_received_subscriptions, libp2p_pubsub_broadcast_unsubscriptions, libp2p_pubsub_messages_rebroadcasted, libp2p_pubsub_received_graft, removeValidator, DefaultMaxIncomingStreams, send, libp2p_pubsub_received_prune, ValidatorHandler, libp2p_pubsub_broadcast_iwant, init, unsubscribe, validate, removeObserver, libp2p_pubsub_broadcast_graft, libp2p_pubsub_received_unsubscriptions, sendSubs, codec, MsgIdProvider, PubSub, SubscriptionValidator, start, onTopicSubscription, updateMetrics, libp2p_pubsub_broadcast_subscriptions, addValidator, KnownLibP2PTopics, handleConn, onPubSubPeerEvent, publish, LPProtocol, ValidationResult, broadcast, subscribe, addObserver, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, unsubscribePeer, rpcHandler, init, KnownLibP2PTopicsSeq, handleData, LPProtoHandler, libp2p_pubsub_received_ihave, new, TopicPair, libp2p_pubsub_broadcast_ihave, subscribePeer, libp2p_pubsub_received_iwant, maxIncomingStreams, libp2p_pubsub_broadcast_messages, initPubSub, libp2p_pubsub_messages_published, TopicHandler, unsubscribeAll, InitializationError, libp2p_pubsub_received_messages, unsubscribe, getOrCreatePeer, stop, publish, initPubSub, addSeen, init, unsubscribePeer, rpcHandler, FloodSubCodec, hasSeen, firstSeen, handleSubscribe, FloodSub, sendSubs, onNewPeer, libp2p_pubsub_received_subscriptions, onTopicSubscription, validateParameters, init, MsgIdProvider, validateParameters, updateScores, libp2p_pubsub_broadcast_iwant, removeValidator, GossipSub, handleIDontWant, GossipSubParams, addObserver, libp2p_pubsub_broadcast_ihave, RoutingRecordsPair, codec, scoringHeartbeat, replenishFanout, GossipSubHeartbeatInterval, onPubSubPeerEvent, start, publish, libp2p_pubsub_broadcast_unsubscriptions, onTopicSubscription, addValidator, TopicInfo, disconnectPeer, onPubSubPeerEvent, publish, updateMetrics, PingsPeerBudget, broadcast, rateLimit, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, byScore, MeshMetrics, GossipSubHistoryLength, handleGraft, GossipBackoffPeriod, rpcHandler, KnownLibP2PTopicsSeq, LPProtoHandler, libp2p_pubsub_received_unsubscriptions, getGossipPeers, GossipSubDhi, TopicPair, init, GossipSubDlo, rewardDelivered, maxIncomingStreams=, libp2p_pubsub_received_iwant, maxIncomingStreams, handleIHave, BackoffTable, start, libp2p_pubsub_messages_published, ValidationSeenTable, TopicHandler, InitializationError, dropFanoutPeers, addDirectPeer, ValidationResult, codec=, removeObserver, IHaveMaxLength, libp2p_pubsub_messages_rebroadcasted, unsubscribe, DefaultMaxIncomingStreams, libp2p_pubsub_received_prune, IHavePeerBudget, ValidatorHandler, GossipSubCodec, heartbeat, rpcHandler, init, BackoffSlackTime, libp2p_gossipsub_peers_rate_limit_hits, libp2p_pubsub_broadcast_graft, peerExchangeList, GossipSubCodec_10, GossipSubHistoryGossip, RoutingRecordsHandler, rebalanceMesh, punishInvalidMessage, handleSubscribe, SubscriptionValidator, init, initPubSub, unsubscribe, libp2p_pubsub_broadcast_subscriptions, pruned, KnownLibP2PTopics, LPProtocol, subscribe, GossipSubFanoutTTL, unsubscribePeer, getOrCreatePeer, validate, handleData, PeerStats, libp2p_pubsub_received_graft, libp2p_pubsub_received_ihave, new, addCapped, grafted, send, subscribePeer, PubSub, handleIWant, init, handlePrune, libp2p_pubsub_broadcast_messages, unsubscribePeer, getOrCreatePeer, initPubSub, withPeerStats, handleConn, GossipSubD, unsubscribeAll, stop, libp2p_pubsub_received_messages, disconnectIfBadScorePeer, handleBackingOff, stop, TopicParams +maxIncomingStreams=, codec=, libp2p_pubsub_received_subscriptions, libp2p_pubsub_broadcast_unsubscriptions, libp2p_pubsub_messages_rebroadcasted, libp2p_pubsub_received_graft, removeValidator, DefaultMaxIncomingStreams, send, libp2p_pubsub_received_prune, ValidatorHandler, libp2p_pubsub_broadcast_iwant, init, unsubscribe, validate, removeObserver, libp2p_pubsub_broadcast_graft, libp2p_pubsub_received_unsubscriptions, sendSubs, codec, MsgIdProvider, PubSub, SubscriptionValidator, start, onTopicSubscription, updateMetrics, libp2p_pubsub_broadcast_subscriptions, addValidator, KnownLibP2PTopics, handleConn, onPubSubPeerEvent, publish, LPProtocol, ValidationResult, broadcast, subscribe, addObserver, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, unsubscribePeer, rpcHandler, init, KnownLibP2PTopicsSeq, handleData, LPProtoHandler, libp2p_pubsub_received_ihave, new, TopicPair, libp2p_pubsub_broadcast_ihave, subscribePeer, libp2p_pubsub_received_iwant, maxIncomingStreams, libp2p_pubsub_broadcast_messages, initPubSub, libp2p_pubsub_messages_published, TopicHandler, unsubscribeAll, InitializationError, libp2p_pubsub_received_messages, unsubscribe, getOrCreatePeer, stop, publish, initPubSub, addSeen, init, unsubscribePeer, rpcHandler, FloodSubCodec, hasSeen, firstSeen, handleSubscribe, FloodSub, sendSubs, onNewPeer, libp2p_pubsub_received_subscriptions, onTopicSubscription, validateParameters, init, MsgIdProvider, validateParameters, updateScores, libp2p_pubsub_broadcast_iwant, removeValidator, GossipSub, handleIDontWant, GossipSubParams, addObserver, libp2p_pubsub_broadcast_ihave, RoutingRecordsPair, codec, scoringHeartbeat, replenishFanout, GossipSubHeartbeatInterval, onPubSubPeerEvent, start, publish, libp2p_pubsub_broadcast_unsubscriptions, onTopicSubscription, addValidator, TopicInfo, disconnectPeer, onPubSubPeerEvent, publish, updateMetrics, PingsPeerBudget, broadcast, rateLimit, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, byScore, MeshMetrics, GossipSubHistoryLength, handleGraft, GossipBackoffPeriod, rpcHandler, KnownLibP2PTopicsSeq, LPProtoHandler, libp2p_pubsub_received_unsubscriptions, getGossipPeers, GossipSubDhi, TopicPair, init, GossipSubDlo, rewardDelivered, maxIncomingStreams=, libp2p_pubsub_received_iwant, maxIncomingStreams, handleIHave, BackoffTable, start, libp2p_pubsub_messages_published, ValidationSeenTable, TopicHandler, InitializationError, dropFanoutPeers, addDirectPeer, ValidationResult, codec=, removeObserver, IHaveMaxLength, libp2p_pubsub_messages_rebroadcasted, unsubscribe, DefaultMaxIncomingStreams, libp2p_pubsub_received_prune, IHavePeerBudget, ValidatorHandler, GossipSubCodec, heartbeat, rpcHandler, init, BackoffSlackTime, libp2p_gossipsub_peers_rate_limit_hits, libp2p_pubsub_broadcast_graft, peerExchangeList, GossipSubCodec_10, GossipSubHistoryGossip, RoutingRecordsHandler, rebalanceMesh, punishInvalidMessage, handleSubscribe, SubscriptionValidator, init, initPubSub, unsubscribe, libp2p_pubsub_broadcast_subscriptions, pruned, KnownLibP2PTopics, LPProtocol, subscribe, GossipSubFanoutTTL, unsubscribePeer, getOrCreatePeer, validate, handleData, PeerStats, libp2p_pubsub_received_graft, libp2p_pubsub_received_ihave, new, addCapped, grafted, send, subscribePeer, PubSub, handleIWant, init, handlePrune, libp2p_pubsub_broadcast_messages, unsubscribePeer, getOrCreatePeer, initPubSub, withPeerStats, handleConn, GossipSubD, unsubscribeAll, stop, libp2p_pubsub_received_messages, disconnectIfBadScorePeer, handleBackingOff, stop, TopicParams
@@ -239,7 +239,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/errors.html b/unstable/libp2p/protocols/pubsub/errors.html index f9af38347..4f5806249 100644 --- a/unstable/libp2p/protocols/pubsub/errors.html +++ b/unstable/libp2p/protocols/pubsub/errors.html @@ -255,7 +255,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/floodsub.html b/unstable/libp2p/protocols/pubsub/floodsub.html index aa5959c39..de6622b3c 100644 --- a/unstable/libp2p/protocols/pubsub/floodsub.html +++ b/unstable/libp2p/protocols/pubsub/floodsub.html @@ -468,7 +468,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/gossipsub.html b/unstable/libp2p/protocols/pubsub/gossipsub.html index 634976a84..1fad54c6c 100644 --- a/unstable/libp2p/protocols/pubsub/gossipsub.html +++ b/unstable/libp2p/protocols/pubsub/gossipsub.html @@ -333,9 +333,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -346,9 +346,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -372,9 +372,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -416,9 +416,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -441,9 +441,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -480,9 +480,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -494,9 +494,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -508,9 +508,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -521,9 +521,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -534,15 +534,15 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit
method unsubscribePeer(g: GossipSub; peer: PeerId) {....raises: [],
-    tags: [WriteIOEffect, TimeEffect].}
+ tags: [WriteIOEffect, TimeEffect, RootEffect].}
handle peer disconnects @@ -558,7 +558,7 @@ class="link-seesrc" target="_blank">Source

Exports

-GossipSubD, IHaveMaxLength, BackoffSlackTime, GossipSubHistoryLength, GossipBackoffPeriod, PeerStats, IHavePeerBudget, GossipSubCodec, GossipSub, GossipSubParams, GossipSubFanoutTTL, GossipSubCodec_10, GossipSubDlo, RoutingRecordsHandler, GossipSubHistoryGossip, GossipSubHeartbeatInterval, MeshMetrics, BackoffTable, RoutingRecordsPair, TopicInfo, ValidationSeenTable, GossipSubDhi, PingsPeerBudget, TopicParams, updateScores, libp2p_gossipsub_peers_rate_limit_hits, disconnectPeer, init, disconnectIfBadScorePeer, withPeerStats, byScore, punishInvalidMessage, rewardDelivered, scoringHeartbeat, addCapped, getGossipPeers, handleIDontWant, replenishFanout, rebalanceMesh, dropFanoutPeers, handleIWant, pruned, handleBackingOff, peerExchangeList, handleGraft, grafted, handleIHave, handlePrune, heartbeat, maxIncomingStreams=, codec=, libp2p_pubsub_received_subscriptions, libp2p_pubsub_broadcast_unsubscriptions, libp2p_pubsub_messages_rebroadcasted, libp2p_pubsub_received_graft, removeValidator, DefaultMaxIncomingStreams, send, libp2p_pubsub_received_prune, ValidatorHandler, libp2p_pubsub_broadcast_iwant, init, unsubscribe, validate, removeObserver, libp2p_pubsub_broadcast_graft, libp2p_pubsub_received_unsubscriptions, sendSubs, codec, MsgIdProvider, PubSub, SubscriptionValidator, start, onTopicSubscription, updateMetrics, libp2p_pubsub_broadcast_subscriptions, addValidator, KnownLibP2PTopics, handleConn, onPubSubPeerEvent, publish, LPProtocol, ValidationResult, broadcast, subscribe, addObserver, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, unsubscribePeer, rpcHandler, init, KnownLibP2PTopicsSeq, handleData, LPProtoHandler, libp2p_pubsub_received_ihave, new, TopicPair, libp2p_pubsub_broadcast_ihave, subscribePeer, libp2p_pubsub_received_iwant, maxIncomingStreams, libp2p_pubsub_broadcast_messages, initPubSub, libp2p_pubsub_messages_published, TopicHandler, unsubscribeAll, InitializationError, libp2p_pubsub_received_messages, unsubscribe, getOrCreatePeer, stop +GossipSubD, IHaveMaxLength, BackoffSlackTime, GossipSubHistoryLength, GossipBackoffPeriod, PeerStats, IHavePeerBudget, GossipSubCodec, GossipSub, GossipSubParams, GossipSubFanoutTTL, GossipSubCodec_10, GossipSubDlo, RoutingRecordsHandler, GossipSubHistoryGossip, GossipSubHeartbeatInterval, MeshMetrics, BackoffTable, RoutingRecordsPair, TopicInfo, ValidationSeenTable, GossipSubDhi, PingsPeerBudget, TopicParams, updateScores, libp2p_gossipsub_peers_rate_limit_hits, disconnectPeer, init, disconnectIfBadScorePeer, withPeerStats, byScore, punishInvalidMessage, rewardDelivered, scoringHeartbeat, addCapped, getGossipPeers, handleIDontWant, replenishFanout, rebalanceMesh, dropFanoutPeers, handleIWant, pruned, handleBackingOff, peerExchangeList, handleGraft, grafted, handleIHave, handlePrune, heartbeat, maxIncomingStreams=, codec=, libp2p_pubsub_received_subscriptions, libp2p_pubsub_broadcast_unsubscriptions, libp2p_pubsub_messages_rebroadcasted, libp2p_pubsub_received_graft, removeValidator, DefaultMaxIncomingStreams, send, libp2p_pubsub_received_prune, ValidatorHandler, libp2p_pubsub_broadcast_iwant, init, unsubscribe, validate, removeObserver, libp2p_pubsub_broadcast_graft, libp2p_pubsub_received_unsubscriptions, sendSubs, codec, MsgIdProvider, PubSub, SubscriptionValidator, start, onTopicSubscription, updateMetrics, libp2p_pubsub_broadcast_subscriptions, addValidator, KnownLibP2PTopics, handleConn, onPubSubPeerEvent, publish, LPProtocol, ValidationResult, broadcast, subscribe, addObserver, PubSubObserver, libp2p_pubsub_broadcast_prune, PubSubPeer, unsubscribePeer, rpcHandler, init, KnownLibP2PTopicsSeq, handleData, LPProtoHandler, libp2p_pubsub_received_ihave, new, TopicPair, libp2p_pubsub_broadcast_ihave, subscribePeer, libp2p_pubsub_received_iwant, maxIncomingStreams, libp2p_pubsub_broadcast_messages, initPubSub, libp2p_pubsub_messages_published, TopicHandler, unsubscribeAll, InitializationError, libp2p_pubsub_received_messages, unsubscribe, getOrCreatePeer, stop
@@ -568,7 +568,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/gossipsub/behavior.html b/unstable/libp2p/protocols/pubsub/gossipsub/behavior.html index 903257d9a..4f5f24135 100644 --- a/unstable/libp2p/protocols/pubsub/gossipsub/behavior.html +++ b/unstable/libp2p/protocols/pubsub/gossipsub/behavior.html @@ -496,7 +496,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/gossipsub/scoring.html b/unstable/libp2p/protocols/pubsub/gossipsub/scoring.html index d28ca5f17..cd037840f 100644 --- a/unstable/libp2p/protocols/pubsub/gossipsub/scoring.html +++ b/unstable/libp2p/protocols/pubsub/gossipsub/scoring.html @@ -447,7 +447,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/gossipsub/types.html b/unstable/libp2p/protocols/pubsub/gossipsub/types.html index 0a8e0475e..305be6619 100644 --- a/unstable/libp2p/protocols/pubsub/gossipsub/types.html +++ b/unstable/libp2p/protocols/pubsub/gossipsub/types.html @@ -780,7 +780,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/mcache.html b/unstable/libp2p/protocols/pubsub/mcache.html index 3b60e4157..d251af2ce 100644 --- a/unstable/libp2p/protocols/pubsub/mcache.html +++ b/unstable/libp2p/protocols/pubsub/mcache.html @@ -403,7 +403,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/peertable.html b/unstable/libp2p/protocols/pubsub/peertable.html index 9b05d9e5a..f99b06073 100644 --- a/unstable/libp2p/protocols/pubsub/peertable.html +++ b/unstable/libp2p/protocols/pubsub/peertable.html @@ -370,7 +370,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/pubsub.html b/unstable/libp2p/protocols/pubsub/pubsub.html index e0725416c..c0d1c470f 100644 --- a/unstable/libp2p/protocols/pubsub/pubsub.html +++ b/unstable/libp2p/protocols/pubsub/pubsub.html @@ -301,8 +301,8 @@ window.addEventListener("DOMContentLoaded", main2); @@ -317,19 +323,26 @@ window.addEventListener("DOMContentLoaded", main2); + @@ -378,9 +391,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -390,9 +403,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -402,9 +415,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -414,9 +427,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -429,9 +442,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -455,14 +468,15 @@ class="link-seesrc" target="_blank">Source appScore*: float64 behaviourPenalty*: float64 overheadRateLimitOpt*: Opt[TokenBucket] + rpcmessagequeue: RpcMessageQueue
  Source -  Edit +  Edit
@@ -474,9 +488,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -487,9 +501,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -500,9 +514,25 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit + + + +
+
RpcMessageQueue = ref object
+  sendPriorityQueue: Deque[Future[void]]
+  nonPriorityQueue: AsyncQueue[seq[byte]]
+  sendNonPriorityTask: Future[void]
+
+
+ + +  Source +  Edit
@@ -517,9 +547,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -529,9 +559,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -541,9 +571,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -553,9 +583,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -565,9 +595,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -578,9 +608,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -590,9 +620,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -602,9 +632,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -614,9 +644,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -629,9 +659,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -641,9 +671,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit @@ -654,36 +684,52 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit -
-
proc send(p: PubSubPeer; msg: RPCMsg; anonymize: bool) {....raises: [], raises: [],
-    tags: [RootEffect].}
+
+
proc send(p: PubSubPeer; msg: RPCMsg; anonymize: bool; isHighPriority: bool): Future[
+    void] {.stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [],
+            tags: [RootEffect].}
+

Asynchronously sends an RPCMsg to a specified PubSubPeer with an option for anonymization.

+

Parameters:

+
  • p: The PubSubPeer instance to which the message is to be sent.
  • +
  • msg: The RPCMsg instance representing the message to be sent.
  • +
  • anonymize: A boolean flag indicating whether the message should be sent with anonymization.
  • +
  • isHighPriority: A boolean flag indicating whether the message should be treated as high priority.
  • +
+

High priority messages are sent immediately, while low priority messages are queued and sent only after all high priority messages have been sent.

  Source -  Edit +  Edit
-
-
proc sendEncoded(p: PubSubPeer; msg: seq[byte]): Future[void] {.
-    stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [],
-    tags: [RootEffect].}
+
+
proc sendEncoded(p: PubSubPeer; msg: seq[byte]; isHighPriority: bool): Future[
+    void] {.stackTrace: false, ...gcsafe, raises: [], raises: [], raises: [],
+            tags: [RootEffect].}
+

Asynchronously sends an encoded message to a specified PubSubPeer.

+

Parameters:

+
  • p: The PubSubPeer instance to which the message is to be sent.
  • +
  • msg: The message to be sent, encoded as a sequence of bytes (seq[byte]).
  • +
  • isHighPriority: A boolean indicating whether the message should be treated as high priority.
  • +
+

High priority messages are sent immediately, while low priority messages are queued and sent only after all high priority messages have been sent.

  Source -  Edit +  Edit
@@ -693,9 +739,22 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit + + +
+
+
proc stopSendNonPriorityTask(p: PubSubPeer) {....raises: [],
+    tags: [WriteIOEffect, TimeEffect, RootEffect].}
+
+ + +  Source +  Edit
@@ -710,9 +769,9 @@ class="link-seesrc" target="_blank">Source   Source -  Edit +  Edit
@@ -731,7 +790,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/rpc/message.html b/unstable/libp2p/protocols/pubsub/rpc/message.html index 8244f6837..1733ad631 100644 --- a/unstable/libp2p/protocols/pubsub/rpc/message.html +++ b/unstable/libp2p/protocols/pubsub/rpc/message.html @@ -342,7 +342,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/rpc/messages.html b/unstable/libp2p/protocols/pubsub/rpc/messages.html index 725d5a59e..68bc51faf 100644 --- a/unstable/libp2p/protocols/pubsub/rpc/messages.html +++ b/unstable/libp2p/protocols/pubsub/rpc/messages.html @@ -645,7 +645,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/rpc/protobuf.html b/unstable/libp2p/protocols/pubsub/rpc/protobuf.html index 53c417ec9..4b6fcdec1 100644 --- a/unstable/libp2p/protocols/pubsub/rpc/protobuf.html +++ b/unstable/libp2p/protocols/pubsub/rpc/protobuf.html @@ -596,7 +596,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/pubsub/timedcache.html b/unstable/libp2p/protocols/pubsub/timedcache.html index 2d781a9b5..953a72d43 100644 --- a/unstable/libp2p/protocols/pubsub/timedcache.html +++ b/unstable/libp2p/protocols/pubsub/timedcache.html @@ -422,7 +422,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/rendezvous.html b/unstable/libp2p/protocols/rendezvous.html index 5df51dff1..ee6587579 100644 --- a/unstable/libp2p/protocols/rendezvous.html +++ b/unstable/libp2p/protocols/rendezvous.html @@ -530,7 +530,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/secure/noise.html b/unstable/libp2p/protocols/secure/noise.html index 9d315ee0a..af98e231d 100644 --- a/unstable/libp2p/protocols/secure/noise.html +++ b/unstable/libp2p/protocols/secure/noise.html @@ -561,7 +561,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/protocols/secure/secure.html b/unstable/libp2p/protocols/secure/secure.html index 33e177cb0..38d7b7b17 100644 --- a/unstable/libp2p/protocols/secure/secure.html +++ b/unstable/libp2p/protocols/secure/secure.html @@ -547,7 +547,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/routing_record.html b/unstable/libp2p/routing_record.html index a003578f1..ff6a5e3ec 100644 --- a/unstable/libp2p/routing_record.html +++ b/unstable/libp2p/routing_record.html @@ -422,7 +422,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/signed_envelope.html b/unstable/libp2p/signed_envelope.html index 733280847..0e4e81244 100644 --- a/unstable/libp2p/signed_envelope.html +++ b/unstable/libp2p/signed_envelope.html @@ -503,7 +503,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/stream/bufferstream.html b/unstable/libp2p/stream/bufferstream.html index 11f8f8190..c82edf83c 100644 --- a/unstable/libp2p/stream/bufferstream.html +++ b/unstable/libp2p/stream/bufferstream.html @@ -513,7 +513,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/stream/chronosstream.html b/unstable/libp2p/stream/chronosstream.html index 8eaba34f6..b18c471f4 100644 --- a/unstable/libp2p/stream/chronosstream.html +++ b/unstable/libp2p/stream/chronosstream.html @@ -497,7 +497,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/stream/connection.html b/unstable/libp2p/stream/connection.html index 2e4132978..e246c18cf 100644 --- a/unstable/libp2p/stream/connection.html +++ b/unstable/libp2p/stream/connection.html @@ -500,7 +500,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/stream/lpstream.html b/unstable/libp2p/stream/lpstream.html index c9c8fc11c..6c7449ec9 100644 --- a/unstable/libp2p/stream/lpstream.html +++ b/unstable/libp2p/stream/lpstream.html @@ -1113,7 +1113,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/stream/streamseq.html b/unstable/libp2p/stream/streamseq.html index a3ad06ed7..0152791a8 100644 --- a/unstable/libp2p/stream/streamseq.html +++ b/unstable/libp2p/stream/streamseq.html @@ -442,7 +442,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/switch.html b/unstable/libp2p/switch.html index f7b472b09..094780393 100644 --- a/unstable/libp2p/switch.html +++ b/unstable/libp2p/switch.html @@ -750,7 +750,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/transcoder.html b/unstable/libp2p/transcoder.html index eeef647de..e44f71fc4 100644 --- a/unstable/libp2p/transcoder.html +++ b/unstable/libp2p/transcoder.html @@ -266,7 +266,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/transports/tcptransport.html b/unstable/libp2p/transports/tcptransport.html index 54c18b514..de4b28833 100644 --- a/unstable/libp2p/transports/tcptransport.html +++ b/unstable/libp2p/transports/tcptransport.html @@ -477,7 +477,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/transports/transport.html b/unstable/libp2p/transports/transport.html index c79b73af4..fd388ae8e 100644 --- a/unstable/libp2p/transports/transport.html +++ b/unstable/libp2p/transports/transport.html @@ -488,7 +488,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/transports/wstransport.html b/unstable/libp2p/transports/wstransport.html index 66925ac27..a6a589abf 100644 --- a/unstable/libp2p/transports/wstransport.html +++ b/unstable/libp2p/transports/wstransport.html @@ -554,7 +554,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/upgrademngrs/muxedupgrade.html b/unstable/libp2p/upgrademngrs/muxedupgrade.html index 6a098c3d1..7e9161c85 100644 --- a/unstable/libp2p/upgrademngrs/muxedupgrade.html +++ b/unstable/libp2p/upgrademngrs/muxedupgrade.html @@ -350,7 +350,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/upgrademngrs/upgrade.html b/unstable/libp2p/upgrademngrs/upgrade.html index 642a24839..f523d5a16 100644 --- a/unstable/libp2p/upgrademngrs/upgrade.html +++ b/unstable/libp2p/upgrademngrs/upgrade.html @@ -370,7 +370,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/utility.html b/unstable/libp2p/utility.html index fd3cfee40..7868e4c17 100644 --- a/unstable/libp2p/utility.html +++ b/unstable/libp2p/utility.html @@ -444,7 +444,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/utils/future.html b/unstable/libp2p/utils/future.html index 091a53bad..8c43116cb 100644 --- a/unstable/libp2p/utils/future.html +++ b/unstable/libp2p/utils/future.html @@ -271,7 +271,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/utils/heartbeat.html b/unstable/libp2p/utils/heartbeat.html index 6e6c7f76c..7fb9254eb 100644 --- a/unstable/libp2p/utils/heartbeat.html +++ b/unstable/libp2p/utils/heartbeat.html @@ -245,7 +245,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/utils/offsettedseq.html b/unstable/libp2p/utils/offsettedseq.html index 45b4165fd..d49e9bdb2 100644 --- a/unstable/libp2p/utils/offsettedseq.html +++ b/unstable/libp2p/utils/offsettedseq.html @@ -512,7 +512,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/utils/semaphore.html b/unstable/libp2p/utils/semaphore.html index 537848c23..210553fde 100644 --- a/unstable/libp2p/utils/semaphore.html +++ b/unstable/libp2p/utils/semaphore.html @@ -362,7 +362,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/varint.html b/unstable/libp2p/varint.html index 44051c6f6..a1bfc8164 100644 --- a/unstable/libp2p/varint.html +++ b/unstable/libp2p/varint.html @@ -725,7 +725,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/vbuffer.html b/unstable/libp2p/vbuffer.html index 43f2824a9..b9840a706 100644 --- a/unstable/libp2p/vbuffer.html +++ b/unstable/libp2p/vbuffer.html @@ -636,7 +636,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/libp2p/wire.html b/unstable/libp2p/wire.html index 2b9805df4..dd43b6ae5 100644 --- a/unstable/libp2p/wire.html +++ b/unstable/libp2p/wire.html @@ -604,7 +604,7 @@ class="link-seesrc" target="_blank">Source diff --git a/unstable/theindex.html b/unstable/theindex.html index d224ceaa6..7041a22b5 100644 --- a/unstable/theindex.html +++ b/unstable/theindex.html @@ -553,7 +553,7 @@ window.addEventListener('DOMContentLoaded', main);
broadcast:
BufferStream:
+
RpcMessageQueue:
RPCMsg:
send:
sendEncoded:
sendHopStatus:
+
stopSendNonPriorityTask:
storeMuxer: