@dxos/broadcast
Advanced tools
Comparing version 1.0.0-beta.8 to 1.0.0-beta.9
@@ -83,3 +83,3 @@ "use strict"; | ||
this._subscribe = next => middleware.subscribe(next); | ||
this._subscribe = (...args) => middleware.subscribe(...args); | ||
@@ -182,13 +182,4 @@ this._seenSeqs = new _lru.default({ | ||
_open() { | ||
const onData = this._onPacket.bind(this); | ||
this._unsubscribe = this._subscribe(this._onPacket.bind(this), this.updatePeers.bind(this)) || (() => {}); | ||
const onPeers = this.updatePeers.bind(this); // deprecated the use of lookup | ||
const next = this._lookup ? onData : { | ||
onData, | ||
onPeers | ||
}; | ||
this._unsubscribe = this._subscribe(next) || (() => {}); | ||
log('running %h', this._id); | ||
@@ -195,0 +186,0 @@ } |
{ | ||
"name": "@dxos/broadcast", | ||
"version": "1.0.0-beta.8", | ||
"version": "1.0.0-beta.9", | ||
"description": "Abstract module to send broadcast messages.", | ||
@@ -5,0 +5,0 @@ "homepage": "https://github.com/dxos/broadcast#readme", |
@@ -57,3 +57,3 @@ # Broadcast | ||
const middleware = { | ||
subscribe: ({ onData, onPeers }) => { | ||
subscribe: (onData, updatePeers) => { | ||
// Defines how to process incoming data and peers update. | ||
@@ -60,0 +60,0 @@ |
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
65254
274