deps: update it-* deps to latest versions (#450)

`it-pipe` can now detect async/vs sync pipelines so update to the
latest version.

Author: achingbrain

package.json

@@ -165,15 +165,15 @@
     "datastore-core": "^9.0.1",
     "hashlru": "^2.3.0",
     "interface-datastore": "^8.0.0",
-    "it-all": "^2.0.0",
-    "it-drain": "^2.0.0",
-    "it-first": "^2.0.0",
-    "it-length": "^2.0.0",
-    "it-length-prefixed": "^8.0.2",
+    "it-all": "^3.0.1",
+    "it-drain": "^3.0.1",
+    "it-first": "^3.0.1",
+    "it-length": "^3.0.1",
+    "it-length-prefixed": "^9.0.0",
     "it-map": "^3.0.1",
-    "it-merge": "^2.0.0",
+    "it-merge": "^3.0.0",
     "it-parallel": "^3.0.0",
-    "it-pipe": "^2.0.3",
+    "it-pipe": "^3.0.0",
     "it-stream-types": "^1.0.4",
     "it-take": "^3.0.1",
     "k-bucket": "^5.1.0",
@@ -199,7 +199,7 @@
     "datastore-level": "^10.0.0",
     "delay": "^5.0.0",
     "execa": "^7.0.0",
-    "it-filter": "^2.0.0",
+    "it-filter": "^3.0.1",
     "it-last": "^3.0.1",
     "lodash.random": "^3.2.0",
     "lodash.range": "^3.2.0",

src/network.ts

@@ -156,7 +156,7 @@ export class Network extends EventEmitter<NetworkEvents> implements Startable {
 
     await pipe(
       [msg],
-      lp.encode(),
+      (source) => lp.encode(source),
       stream,
       drain
     )
@@ -174,9 +174,9 @@ export class Network extends EventEmitter<NetworkEvents> implements Startable {
 
     const res = await pipe(
       [msg],
-      lp.encode(),
+      (source) => lp.encode(source),
       stream,
-      lp.decode(),
+      (source) => lp.decode(source),
       async source => {
         const buf = await first(source)
 

src/rpc/index.ts

@@ -90,7 +90,7 @@ export class RPC {
 
       await pipe(
         stream,
-        lp.decode(),
+        (source) => lp.decode(source),
         async function * (source) {
           for await (const msg of source) {
             // handle the message
@@ -104,7 +104,7 @@ export class RPC {
             }
           }
         },
-        lp.encode(),
+        (source) => lp.encode(source),
         stream
       )
     })

test/network.spec.ts

@@ -63,9 +63,9 @@ describe('Network', () => {
 
             const data = await pipe(
               [msg.serialize()],
-              lp.encode(),
+              (source) => lp.encode(source),
               source => map(source, arr => new Uint8ArrayList(arr)),
-              async (source) => await all(source)
+              async (source) => all(source)
             )
 
             const source = (function * () {
@@ -77,7 +77,7 @@ describe('Network', () => {
             const sink: Sink<Uint8ArrayList | Uint8Array> = async source => {
               const res = await pipe(
                 source,
-                lp.decode(),
+                (source) => lp.decode(source),
                 async (source) => await all(source)
               )
               expect(Message.deserialize(res[0]).type).to.eql(MESSAGE_TYPE.PING)

test/rpc/index.node.ts

@@ -78,19 +78,19 @@ describe('rpc', () => {
 
     peerRouting.getCloserPeersOffline.resolves([])
 
-    const source = await pipe(
+    const source = pipe(
       [msg.serialize()],
-      lp.encode(),
+      (source) => lp.encode(source),
       source => map(source, arr => new Uint8ArrayList(arr)),
-      async (source) => await all(source)
+      (source) => all(source)
     )
 
     const duplexStream: Duplex<Uint8ArrayList, Uint8ArrayList | Uint8Array> = {
       source,
       sink: async (source) => {
         const res = await pipe(
           source,
-          lp.decode(),
+          (source) => lp.decode(source),
           async (source) => await all(source)
         )
         validateMessage(res)