Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

level-read-stream

Package Overview
Dependencies
Maintainers
0
Versions
4
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

level-read-stream

Read from an abstract-level database using Node.js streams

  • 1.1.1
  • latest
  • Source
  • npm
  • Socket score

Version published
Weekly downloads
17K
increased by22.67%
Maintainers
0
Weekly downloads
 
Created
Source

level-read-stream

Read from an abstract-level database using Node.js streams.

:pushpin: To instead consume data using Web Streams, see level-web-stream.

level badge npm Node version Test Coverage Standard Common Changelog Donate

Usage

If you are migrating from levelup or level <= 7: please see UPGRADING.md.

const { EntryStream } = require('level-read-stream')
const { Writable, pipeline } = require('readable-stream')

await db.put('a', '1')
await db.put('b', '2')
await db.put('c', '3')

const src = new EntryStream(db, {
  gte: 'b'
})

const dst = new Writable({
  write (entry, _, next) {
    console.log('%s: %s', entry.key, entry.value)
    next()
  }
})

pipeline(src, dst)

Yields:

b: 2
c: 3

To only read keys or values rather than entries:

const { KeyStream, ValueStream } = require('level-read-stream')

pipeline(new KeyStream(db), new Writable({
  write (key, _, next) {
    console.log(key)
    next()
  }
}))

Install

With npm do:

npm install level-read-stream

Usage from TypeScript also requires npm install @types/readable-stream.

API

stream = new EntryStream(db[, options])

Create a readable stream that will yield entries. An entry is an object with key and value properties. The db argument must be an abstract-level database. The optional options object may contain:

  • highWaterMark (number): the maximum number of entries to buffer internally before ceasing to read further entries. Default 1000.

Any other options are forwarded to db.iterator(options). The stream wraps that iterator. If you prefer to consume entries with for await...of then it's recommended to directly use db.iterator(). In either case, most databases will read from a snapshot (thus unaffected by simultaneous writes) as indicated by db.supports.snapshots.

Upon stream end or having called stream.destroy() the underlying iterator will be closed after which a close event is emitted on the stream.

stream = new KeyStream(db[, options])

Same as EntryStream but yields keys instead of entries, using db.keys() instead of db.iterator(). If only keys are needed, using KeyStream may increase performance because values won't have to be fetched.

stream = new ValueStream(db[, options])

Same as EntryStream but yields values instead of entries, using db.values() instead of db.iterator(). If only values are needed, using ValueStream may increase performance because keys won't have to be fetched.

stream

An instance of EntryStream, KeyStream or ValueStream has the following special properties.

stream.db

A read-only reference to the database that this stream is reading from.

Contributing

Level/read-stream 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.

Donate

Support us with a monthly donation on Open Collective and help us continue our work.

License

MIT

Keywords

FAQs

Package last updated on 22 Oct 2024

Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc