.. | ||
fixtures | ||
.travis.yml | ||
bench.js | ||
check.js | ||
example.js | ||
index.js | ||
LICENSE | ||
package.json | ||
README.md | ||
test.js |
sonic-boom
Extremely fast utf8-only stream implementation to write to files and file descriptors.
This implementation is partial, but support backpressure and .pipe()
in is here.
However, it is 2-3x faster than Node Core fs.createWriteStream()
:
benchSonic*1000: 2215.220ms
benchSonicSync*1000: 8315.173ms
benchSonic4k*1000: 2184.558ms
benchSonicSync4k*1000: 1733.582ms
benchCore*1000: 6513.752ms
Note that sync mode without buffering is slower than a Node Core WritableStream, however
this mode matches the expected behavior of console.log()
.
Note that if this is used to log to a windows terminal (cmd.exe
or
powershell), it is needed to run chcp 65001
in the terminal to
correctly display utf-8 characters, see
chcp for more details.
Install
npm i sonic-boom
Example
'use strict'
const SonicBoom = require('sonic-boom')
const sonic = new SonicBoom(process.stdout.fd) // or '/path/to/destination'
for (var i = 0; i < 10; i++) {
sonic.write('hello sonic\n')
}
API
SonicBoom(String|Number, [minLength], [sync])
Creates a new instance of SonicBoom.
The first argument can be:
- a string that is a path to a file to be written to (mode
'a'
) - a file descriptor, something that is returned by
fs.open
orfs.openSync
.
The second argument is the minimum length of the internal buffer that is required before flushing.
The third argument is a flag that, when true, causes SonicBoom
to perform synchronous writes.
It will emit the 'ready'
event when a file descriptor is available.
SonicBoom#write(string)
Writes the string to the file. It will return false to signal the producer to slow down.
SonicBoom#flush()
Writes the current buffer to the file if a write was not in progress.
Do nothing if minLength
is zero or if it is already writing.
SonicBoom#reopen([file])
Reopen the file in place, useful for log rotation.
Example:
const stream = new SonicBoom('./my.log')
process.on('SIGUSR2', function () {
stream.reopen()
})
SonicBoom#flushSync()
Flushes the buffered data synchronously. This is a costly operation.
SonicBoom#end()
Closes the stream, the data will be flushed down asynchronously
SonicBook#destroy()
Closes the stream immediately, the data is not flushed.
License
MIT