@dxos/broadcast
Advanced tools
Comparing version 1.0.0-beta.5 to 1.0.0-beta.6
@@ -210,4 +210,9 @@ "use strict"; | ||
if (packet.origin.equals(peer.id) || packet.from.equals(peer.id)) return Promise.resolve(); // Don't send the message to neighbors that have already seen the message. | ||
if (packet.origin.equals(peer.id) || packet.from.equals(peer.id)) { | ||
this._seenSeqs.add(msgId(packet.seqno, peer.id)); | ||
return Promise.resolve(); | ||
} // Don't send the message to neighbors that have already seen the message. | ||
if (this._seenSeqs.has(msgId(packet.seqno, peer.id))) return Promise.resolve(); | ||
@@ -214,0 +219,0 @@ log('publish %h -> %h', this._id, peer.id, packet); |
{ | ||
"name": "@dxos/broadcast", | ||
"version": "1.0.0-beta.5", | ||
"version": "1.0.0-beta.6", | ||
"description": "Abstract module to send broadcast messages.", | ||
@@ -5,0 +5,0 @@ "homepage": "https://github.com/dxos/broadcast#readme", |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
74374
413