Use pull.take

2017-04-20 14:03:41 -07:00
parent b415e82d71
commit 7435396e31
1 changed files with 1 additions and 11 deletions
@@ -178,16 +178,6 @@ exports.init = function (sbot, config) {
      )
  }

-  function take (n) {
-      return function (read) {
-	  return function (abort, cb) {
-	      //after n reads, tell the source to abort!
-	      if(!n--) return read(true, cb)
-	      read(null, cb)
-	  }
-      }
-  }
-
  function serveFeeds(req, res, following, channelSubscriptions, feedId) {
      var opts = defaultOpts
      
@@ -211,7 +201,7 @@ exports.init = function (sbot, config) {
 		  (msg.value.author in following ||
 		   msg.value.content.channel in channelSubscriptions)
 	  }),
-	  take(100),
+	  pull.take(2),
 	  pull.collect(function (err, logs) {
 	      if (err) return respond(res, 500, err.stack || err)
 	      res.writeHead(200, {