k-rpc - npm Package Compare versions

Comparing version 1.0.0 to 1.0.1

index.js

@@ -94,4 +94,2 @@ var socket = require('k-rpc-socket')
 
-  var self = this
-  var i = 0
   var stop = false
@@ -101,15 +99,8 @@ var missing = nodes.length
 
-  send()
-
-  function send () {
-    for (; i < nodes.length; i++) {
-      if (self.socket.inflight >= self.concurrency || stop) return
-      if (message.a) message.a.token = nodes[i].token
-      self._query(nodes[i], message, done)
-    }
+  for (var i = 0; i < nodes.length; i++) {
+    if (message.a) message.a.token = nodes[i].token
+    this._query(nodes[i], message, done)
   }
 
   function done (err, res, peer) {
-    send()
-
     if (!err) hits++
@@ -116,0 +107,0 @@ if (!err && !stop) {

package.json

 {
   "name": "k-rpc",
-  "version": "1.0.0",
+  "version": "1.0.1",
   "description": "Low-level implementation of the k-rpc protocol used the BitTorrent DHT.",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -87,2 +87,11 @@ # k-rpc
 
+You can return `false` from onreply to stop the query. This is useful if you are only looking for a single peer for example.
+
+``` js
+function onreply(message, node) {
+  console.log('will only fire once')
+  return false
+}
+```
+
 #### `rpc.query(node, query, callback)`
@@ -89,0 +98,0 @@

No alert changes

Improved metrics

Total package byte prevSize

12994

increased by0.64%

Number of lines in readme file

134

increased by7.2%

Worsened metrics

Lines of code

254

decreased by-2.68%

No dependency changes