Test event order of destroy

level-ws

A basic writable stream for abstract-level databases, using Node.js core streams. This is not a high-performance stream. If benchmarking shows that your particular usage does not fit then try one of the alternative writable streams that are optimized for different use cases.

📌 To instead write data using Web Streams, see level-web-stream.

Usage

If you are upgrading: please see UPGRADING.md.

const { Level } = require('level')
const WriteStream = require('level-ws')

const db = new Level('./db', { valueEncoding: 'json' })
const ws = new WriteStream(db)

ws.on('close', function () {
  console.log('Done!')
})

ws.write({ key: 'alice', value: 42 })
ws.write({ key: 'bob', value: 7 })

// To delete entries, specify an explicit type
ws.write({ type: 'del', key: 'tomas' })
ws.write({ type: 'put', key: 'sara', value: 16 })

ws.end()

API

`ws = new WriteStream(db[, options])`

Create a writable stream that operates in object mode, accepting batch operations to be committed with db.batch() on each tick of the Node.js event loop. The optional options argument may contain:

type (string, default: 'put'): default batch operation type if not set on indididual operations.
maxBufferLength (number, default Infinity): limit the size of batches. When exceeded, the stream will stop processing writes until the current batch has been committed.
highWaterMark (number, default 16): buffer level when stream.write() starts returning false.

Contributing

Level/level-ws is an OPEN Open Source Project. This means that:

Individuals making significant and valuable contributions are given commit-access to the project to contribute as they see fit. This project is more like an open wiki than a standard guarded open source project.

See the Contribution Guide for more details.

License

MIT

	WriteStream.prototype._destroy = function (err, cb) {
	this._buffer = null
	this.emit('close')
	cb(err)
	}

Branch	Build failing 🚨
Dependency	`level`
Current Version	3.0.0
Type	devDependency

Branch	Build failing 🚨
Dependency	level
Current Version	1.7.0
Type	devDependency

Branch	Build failing 🚨
Dependency	readable-stream
Current Version	2.3.4
Type	dependency

	} else if (this._buffer && this._buffer.length) {
	this.once('_flush', cb)
	this._flush()
	} else {

	WriteStream.prototype.destroySoon = function () {
	this.end()
	}

	if (!self.emit('_flush', err) && err) {
	// There was no _flush listener.
	self.destroy(err)
	}

	if (self._options.maxBufferLength &&
	self._buffer.length > self._options.maxBufferLength) {
	self.once('_flush', next)
	} else {

level / level-ws Goto Github PK

level-ws's Introduction

level-ws

Usage

API

ws = new WriteStream(db[, options])

Contributing

License

level-ws's People

Contributors

Stargazers

Watchers

Forkers

level-ws's Issues

Version 3.0.1 of level was just published.

Version 2.0.0 of level was just published.

Version 10 of Node.js (code name Dubnium) has been released! 🎊

Version 2.3.5 of readable-stream was just published.

Version 2.3.4 of readable-stream was just published.

Version 4.9.1 of tape was just published.

Version 4.0.0 of level was just published.

Changed

Removed

Recommend Projects

Recommend Topics

Recommend Org

`ws = new WriteStream(db[, options])`