writsy

Write stream wrapper that supports async initialization and flush function.

npm install writsy

var ws = writsy([opts])

var ws = writsy.obj([opts])

Wraps a new writable stream (or object stream) by passing init callback function. Supports optional flush function that is called before 'finish' emitted.

1var writsy = require('writsy')
2...
3
4var ws = writsy({
5  init (cb) {
6    // async initialization, error handling
7    mkdirp('/tmp/foo/', (err) => {
8      if (err) return cb(err)
9      cb(null, fs.createWriteStream('/tmp/foo/bar.txt'))
10    })
11  },
12  flush (cb) {
13    // flush before finish
14    fs.rename('/tmp/foo/bar.txt', './dest.txt', cb)
15  }
16})
17
18fs.createReadStream('loremipsum.txt').pipe(ws)

Or class inheritance by setting _init and _flush methods:

1var Writsy = require('writsy')
2
3class Writer extends Writsy {
4  constructor (opts) {
5    super(opts)
6  }
7  _init (cb) {
8    // async initialization, error handling
9    mkdirp('/tmp/foo/', (err) => {
10      if (err) return cb(err)
11      cb(null, fs.createWriteStream('/tmp/foo/bar.txt'))
12    })
13  }
14  _flush (cb) {
15    // flush before finish
16    fs.rename('/tmp/foo/bar.txt', './dest.txt', cb)
17  }
18}
19
20fs.createReadStream('loremipsum.txt').pipe(new Writer())

License

MIT