concurrent-streams v0.0.1-dev
concurrent-streams
Node.js safe multiple concurrent readable and writable streams from the same file.
Install
$ yarn add concurrent-streams
Quick Usage
// TODO
API
new ConcurrentStream(path, [options])
path: string
options?: StreamOptions
flags?: string
Default:'r+'
fd?: number
Default:undefined
mode?: number
Default:0o666
autoClose?: boolean
Default:true
- Returns: instance of
ConcurrentStream
.
flags
mode when opening a file. See file system flags.
path
will be ignored if fd
is set, and no open
event will be emitted.
mode
sets the file permission if the file was created.
If autoClose
is true
, the file descriptor will be closed if no ReadStream
or WriteStream
referencing it. If autoClose
is false
it is the application's responsibility to close it and make sure there are no leak.
createReadStream([options])
options?: ReadStreamOptions
encoding?: string
Default:'utf8'
start?: number
Default:0
end?: number
Default:Infinity
highWaterMark
Default:128 * 1024
- Returns: instance of
ReadStream
, extendingstream.Readable
.
encoding
can be any one of those accepted by Buffer
.
start
and end
can be used to read a range of bytes from the file. Both start
and end
is inclusive and start counting at 0.
highWaterMark
is for readable stream high water mark.
createWriteStream([options])
options?: ReadStreamOptions
encoding?: string
Default:'utf8'
start?: number
Default:0
- Returns: instance of
WriteStream
, extendingstream.Writable
.
encoding
can be any one of those accepted by Buffer
.
start
can be used to write data at some position past beginning of the file.
Class: ConcurrentStream
Event: 'open'
fd: number
file descriptor used.
Emitted when file descriptor has been opened.
Event: 'close'
Emitted when file descriptor has been closed.
Event: 'error'
Emitted when error occured.
Class: ReadStream
Event: 'read'
bytesRead: number
, number of bytes read.
Emitted every time bytes has been succesfully read from file.
Event: 'error'
Error
Emitten when error occured.
Property: readStream.position
Current offset from beginning of file.
Class: WriteStream
Event: 'written'
bytesWritten: number
, number of bytes written.
Emitted every time bytes has been succesfully written to file.
Event: 'finish'
Emitted when all data has been flushed to underlying system.
Event: 'error'
Error
Emitten when error occured.
Property: writeStream.position
Current offset from beginning of file.
License
5 years ago