maxogden/dat-core

Lightweight debugging utility for Node.js and the browser

Call a callback when a readable/writable/duplex stream has completed or failed.

A low-level Node.js LevelDB binding

Fast & simple storage - a Node.js-style LevelDB wrapper

Recursively mkdir, like `mkdir -p`

pipe streams together and close all of them if one of them closes

Combine an array of streams into a single duplex stream using pump and duplexify

Split a levelup database into sublevels with their own keyspace, encoding and events

A tiny wrapper around Node.js streams.Transform (Streams2/3) to avoid explicit subclassing noise

extend like a boss

LevelUp + MemDown

JavaScript Standard Style

tap-producing test harness for node and browsers

Execute several async functions and get a callback when they are all done

through stream that buffers streams into batches limited by a cumulative byte size limit

Collision-resistant ids optimized for horizontal scaling and performance. For node and browsers.

The blob store dat uses per default

Turn a writable and readable stream into a streams2 duplex stream with support for async initialization and streams1/streams2 input

A hash function that wraps all input chunks with a length prefix.

Merkle DAG that replicates based on scuttlebutt logs and causal linking

Error types for levelup

create lexicographic string keys for positive integers without zero-padding

multilevel implemented using leveldowns with reconnect support

A binary stream multiplexer. Stream multiple streams of binary data over a single binary stream.

A stream that emits multiple other streams one after another (streams3)

mutex lock for javascript

Transform stream that allows you to run your transforms in parallel without changing the order

Streaming encoder/decoder for protocol buffers

Protocol Buffers for Node.js

given two sorted streams will emit only pairs that do not match

Get the union of two sorted streams

Buffer data from a stream into an array if a callback is provided

Iterate through the values of a stream

delay the evaluation of a paramless async function and cache the result