update to modern pull-stream api

test/key-value-stream.js

@@ -11,25 +11,28 @@ tape('keys', function (t) {
 
   var db = sublevel(level()).sublevel('test')
 
-  pull.count(10)
-    .pipe(pull.map(function (i) {
+  pull(
+    pull.count(10),
+    pull.map(function (i) {
       return {key: 'key_'+i, value: 'value_' + i}
-    }))
-    .pipe(pl.write(db, function (err) {
+    }),
+    pl.write(db, function (err) {
       if(err) {
         t.notOk(err)
         throw err
       }
 
-      toPull(db.createKeyStream())
-        .pipe(pull.collect(function (err, ary) {
+      pull(
+        toPull(db.createKeyStream()),
+        pull.collect(function (err, ary) {
           console.log(ary)
           ary.forEach(function (e) {
             t.equal(typeof e, 'string')
             t.ok(/^key_/.test(e))
           })
-          toPull(db.createValueStream())
-            .pipe(pull.collect(function (err, ary) {
+          pull(
+            toPull(db.createValueStream()),
+            pull.collect(function (err, ary) {
               console.log(ary)
               ary.forEach(function (e) {
                 t.equal(typeof e, 'string')
@@ -38,8 +41,11 @@ tape('keys', function (t) {
               })
 
               t.end()
-            }))
-        }))
-    }))
+            })
+          )
+        })
+      )
+    })
+  )
 })
 

test/level.js

@@ -217,3 +217,4 @@ codex.forEach(function (codec) {
   })
 
 })
+