initial

Author: dominictarr

.travis.yml

@@ -0,0 +1,4 @@
+language: node_js
+node_js:
+  - 0.6
+  - 0.8

LICENSE

@@ -0,0 +1,22 @@
+Copyright (c) 2016 Dominic Tarr
+
+Permission is hereby granted, free of charge, 
+to any person obtaining a copy of this software and 
+associated documentation files (the "Software"), to 
+deal in the Software without restriction, including 
+without limitation the rights to use, copy, modify, 
+merge, publish, distribute, sublicense, and/or sell 
+copies of the Software, and to permit persons to whom 
+the Software is furnished to do so, 
+subject to the following conditions:
+
+The above copyright notice and this permission notice 
+shall be included in all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, 
+EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES 
+OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. 
+IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR 
+ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, 
+TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE 
+SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1,42 @@
+# pull-next
+
+read from one pull-stream, then the next, then the next...
+
+when one stream end (unless it errored) call a function
+to get the next stream. much like [pull-cat](https://github.com/pull-stream/pull-cat)
+except creates streams by calling a function instead of takeing them out of an array.
+
+in particular, this is useful for making a read stream that reconnects
+to a source.
+
+## example
+
+create a stream that reads from a leveldb 100 items at a time.
+
+``` js
+var next = require('pull-next')
+var pl = require('pull-level')
+var db = require('level')(path_to_level)
+
+function resume () {
+  var last = null
+  return Next(function () {
+    return pull(
+      pl.read(db, {gt: last && last.key, limit: 100}),
+      pull.through(function (data) { last = data })
+    )
+  })
+}
+
+```
+
+hint: this might be even more useful over [multilevel](https://github.com/level/multilevel)
+
+## License
+
+MIT
+
+
+
+
+

index.js

@@ -0,0 +1,48 @@
+var noop = function () {}
+
+module.exports = function (next) {
+  var stream
+  return function (abort, cb) {
+    if(abort) {
+      if(stream) stream(abort, cb)
+      else       cb(abort)
+    }
+    else
+      more()
+
+    function more () {
+      if(!stream) {
+        try { stream = next() }
+        catch(err) { return cb(err) }
+        if(!stream) return cb(true)
+      }
+      stream(null, function (err, data) {
+        if(err) {
+          console.log('end', err, data)
+          stream = null
+          if(err === true) setTimeout(more, 100)
+          else             cb(err)
+        }
+        else
+          cb(null, data)
+      })
+    }
+  }
+}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+

package.json

@@ -0,0 +1,19 @@
+{
+  "name": "pull-next",
+  "description": "",
+  "version": "0.0.0",
+  "homepage": "https://github.com/dominictarr/pull-next",
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/dominictarr/pull-next.git"
+  },
+  "dependencies": {
+  },
+  "devDependencies": {
+  },
+  "scripts": {
+    "test": "set -e; for t in test/*.js; do node $t; done"
+  },
+  "author": "Dominic Tarr <[email protected]> (http://dominictarr.com)",
+  "license": "MIT"  
+}