diff --git a/index.js b/index.js index b5c1b2a..2d84319 100644 --- a/index.js +++ b/index.js @@ -13,6 +13,7 @@ module.exports = function (file, opts) { var blockSize = opts.blockSize || 1024*16 var codec = opts.codec || {encode: id, decode: id, buffer: true} + var flags = opts.flags || 'a+' var cache = opts.cache || Cache(1024) var offsetCodec = opts.offsetCodec || 32 diff --git a/inject.js b/inject.js index dfe7f37..f5f0a92 100644 --- a/inject.js +++ b/inject.js @@ -124,6 +124,9 @@ module.exports = function (blocks, frame, codec, file, cache) { )).catch((err) => cb(err)) .then(() => cb(null)) }, + close: function (cb) { + cb() + }, methods: { del: 'async' } @@ -131,6 +134,3 @@ module.exports = function (blocks, frame, codec, file, cache) { } - - - diff --git a/bench.js b/test/bench.js similarity index 90% rename from bench.js rename to test/bench.js index ecd6cc6..6113a92 100644 --- a/bench.js +++ b/test/bench.js @@ -1,4 +1,4 @@ -var FlumeLog = require('./') +var FlumeLog = require('../') var codec = require('flumecodec') require('bench-flumelog')(function () { diff --git a/test/flumelog.js b/test/flumelog.js index 1f3efd1..6bbad48 100644 --- a/test/flumelog.js +++ b/test/flumelog.js @@ -3,8 +3,8 @@ var create = require('../') var testLog = require('test-flumelog') function test(name, opts, cb) { - testLog(function () { - return create('/tmp/test_flumelog-offset_'+Date.now(), Object.assign({ + testLog(function (filename) { + return create(filename, Object.assign({ blockSize: 1024, codec: { encode: function (v) {