@dxos/broadcast - npm Package Compare versions

Comparing version 2.33.5-dev.b7c9d504 to 2.33.5-dev.bbe0c471

dist/src/broadcast.test.js

@@ -63,14 +63,10 @@ "use strict";
 }
-async function publishAndSync(peers, message, opts) {
+const publishAndSync = async (peers, message, opts) => {
     const [peerOrigin, ...peersTarget] = peers;
-    const sync = Promise.all(peersTarget.map((peer) => {
-        return new Promise(resolve => peer.once('packet', () => resolve()));
-    }));
+    const sync = Promise.all(peersTarget.map((peer) => new Promise(resolve => peer.once('packet', () => resolve()))));
     const packet = await peerOrigin.publish(message, opts);
     await sync;
-    expect(peersTarget.reduce((prev, curr) => {
-        return prev && curr.messages.has(packetId(packet));
-    }, true)).toBe(true);
+    expect(peersTarget.reduce((prev, curr) => prev && curr.messages.has(packetId(packet)), true)).toBe(true);
     return packet;
-}
+};
 test('balancedBinTree: broadcast a message.', async () => {
@@ -108,5 +104,3 @@ const generator = new network_generator_1.NetworkGenerator({
     // The cache should have always the limit of 100.
-    expect(network.peers.slice(1).reduce((prev, next) => {
-        return prev && next.seenMessagesSize === 2;
-    }, true)).toBeTruthy();
+    expect(network.peers.slice(1).reduce((prev, next) => prev && next.seenMessagesSize === 2, true)).toBeTruthy();
     time = Date.now() - time;
@@ -117,7 +111,5 @@ if (time < 2000) {
     network.peers.forEach((peer) => peer.prune());
-    expect(network.peers.reduce((prev, next) => {
-        return prev && next.seenMessagesSize === 0;
-    }, true)).toBeTruthy();
+    expect(network.peers.reduce((prev, next) => prev && next.seenMessagesSize === 0, true)).toBeTruthy();
     network.peers.forEach((peer) => peer.close());
 });
 //# sourceMappingURL=broadcast.test.js.map

package.json

 {
   "name": "@dxos/broadcast",
-  "version": "2.33.5-dev.b7c9d504",
+  "version": "2.33.5-dev.bbe0c471",
   "description": "Abstract module to send broadcast messages.",
@@ -18,5 +18,5 @@ "repository": {
   "dependencies": {
-    "@dxos/async": "2.33.5-dev.b7c9d504",
-    "@dxos/codec-protobuf": "2.33.5-dev.b7c9d504",
-    "@dxos/crypto": "2.33.5-dev.b7c9d504",
+    "@dxos/async": "2.33.5-dev.bbe0c471",
+    "@dxos/codec-protobuf": "2.33.5-dev.bbe0c471",
+    "@dxos/crypto": "2.33.5-dev.bbe0c471",
     "debug": "^4.3.3",
@@ -26,4 +26,4 @@ "tiny-lru": "^7.0.6"
   "devDependencies": {
-    "@dxos/eslint-plugin": "~1.0.27",
-    "@dxos/network-generator": "2.33.5-dev.b7c9d504",
+    "@dxos/eslint-plugin": "~1.0.31",
+    "@dxos/network-generator": "2.33.5-dev.bbe0c471",
     "@dxos/protocols-toolchain": "2.33.4",
@@ -30,0 +30,0 @@ "@types/debug": "^4.1.7",

No alert changes

Worsened metrics

Total package byte prevSize

72557

decreased by-0.22%

Lines of code

522

decreased by-1.51%

Dependency changes

• + Added@dxos/[e-mail]0c471(transitive)

• + Added@dxos/[e-mail]0c471(transitive)

• + Added@dxos/[e-mail]0c471(transitive)

• + Added@dxos/[e-mail]0c471(transitive)

• - Removed@dxos/async@2.33.5-dev.b7c9d504(transitive)

• - Removed@dxos/codec-protobuf@2.33.5-dev.b7c9d504(transitive)

• - Removed@dxos/crypto@2.33.5-dev.b7c9d504(transitive)

• - Removed@dxos/debug@2.33.5-dev.b7c9d504(transitive)

• Updated@dxos/[e-mail]0c471

• Updated@dxos/[e-mail]0c471

• Updated@dxos/[e-mail]0c471