async-flumelog - npm Package Compare versions

Comparing version 1.0.4 to 1.0.5

index.js

@@ -233,4 +233,4 @@ const Cache = require('hashlru')
               stream.cursor = 0
-            else if (getNextBlockIndex(stream.cursor) < since.value)
-              stream.cursor = getNextBlockIndex(stream.cursor)
+            else // the cursor still at last position
+              stream.skipFirst = true
 
@@ -237,0 +237,0 @@ stream.writing = true

package.json

 {
   "name": "async-flumelog",
   "description": "An async flumelog",
-  "version": "1.0.4",
+  "version": "1.0.5",
   "homepage": "https://github.com/flumedb/async-flumelog",
@@ -6,0 +6,0 @@ "repository": {

test/stream.js

@@ -141,1 +141,39 @@ var tape = require('tape')
 })
+
+tape('live gt', function (t) {
+  var v4 = B(0x40, 40)
+  var sink = collect(function () {
+    throw new Error('live stream should not end')
+  })
+  log.stream({ live: true, seqs: false, gt: 10 + 2 + 20 + 2 }).pipe(sink)
+  log.append(v4, function (err) {})
+  log.onDrain(() => {
+    // need to wait for stream to get changes from save
+    setTimeout(() => {
+      t.deepEqual(sink.array, [v4])
+      t.end()
+    }, 200)
+  })
+})
+
+tape('double live', function (t) {
+  const filename = '/tmp/dsf-test-stream-2.log'
+
+  try { fs.unlinkSync(filename) } catch (_) {}
+  var log = Log(filename, {blockSize: 64*1024})
+
+  var i = 0
+
+  log.stream({ live: true, seqs: false }).pipe({
+    paused: false,
+    write: function (data) {
+      if (i == 0) {
+        log.append(B(0x20, 20), function (err) {})
+        ++i
+      } else
+        t.end()
+    }
+  })
+
+  log.append(B(0x10, 10), function (err) {})
+})

No alert changes

Improved metrics

Total package byte prevSize

37388

increased by2.32%

Lines of code

1044

increased by3.16%

No dependency changes