Dominic Tarr

Create HyperText with JavaScript, on client or server.

construct pipes of streams of events

rawStream.pipe(JSONStream.parse()).pipe(streamOfObjects)

replicate data via scuttlebutt protocol

hardwired configuration loader

simplified stream construction

split a Text Stream into a Line Stream

return random last names.

flexible but simple curry function

modular database made from streams of logs

simpler faster substitute for LRU

partition levelup databases

multiplex streams

iteratively fund open-source projects

convert a stream of xls or xlsx into json on the command line or in node

executable specification for Stream (to make testing streams easy)

construct pipes of streams of events

encrypt a message to a secret number of recipients

[](https://npmjs.org/package/stream-combiner) [](https://travis-ci.org/dominictarr/stream-combiner)

stack expressions are similar to regular expressions, but can parse nested structures.

Easy way to make a Readable Stream

wrap errors in explainations.

check finite state machine properties

dominictarr style base64, like base64 but lexiographically sortable

scuttlebutt style replication for level-*

lock asynchronous resources.

Monotonically increasing timestamp.

encode/decode with same encoded sort order as bytewise

JSON parse & stringify that supports binary via bops & base64

pre/post hooks for leveldb

browser polyfil for sodium

an append oriented kv store for streams

Create a computer vision endpoint in seconds

dynamic shortest path algorithim

convert a stream1 or streams2 stream into a pull-stream

prototype bootloader for the offline web.

pull-stream interface to levelup

merkle tree replication.

Single function that return the sha1sum. Installing this is just a little bit quicker than reading the crypto documentation.

pull-stream with a push interface

peer2peer nodejs applications

No description available

wrap a stream of regular js objects into a stream of line seperated json.

async loops that never RangeError

base class for a duplex stream

tell me my local ip address

re-stream a parsed body so that it can be proxied.

gossip requests for out-of-order messages on ssb

Generate musical voices with FM synthesis.

implement correct ranges for level-*

simple and lightweight observer

peek the first or last record in a leveldb range.

get consistent post hooks for leveldb.

websocket & http server for ssb

concatenate pull-streams

A pull-stream over series that have an index.

Aggregate a pull-stream into windows.

a deferred source, sink or through pull-stream

make http client requests in pull streamy ways.

:warning:

sort ssb messages by cryptographic order

hash timestamped objects into increasingly larger groups

efficiently store signed integers in varint

through ported to pull-stream style

port of Dmitry Chestnykh's blake2s-js to node style

make using levelup reverse ranges easy

see if you have a non private (i.e. public ip address)

wrap a push-stream into a pull-stream, for source, sink, and duplex.

lighter wrapper around leveldown: adds encodings and pull-streams.

track the rate of flow of a pull-stream.

kill a duplex pull-stream after period of inactivity.

pad semver to make it lexiographically sortable

nodejs redis client with no extras

utility belt was (Dominic's Utilities)

a pull-stream which may be aborted

test vectors for hashes

simplest levelup reader

a secure, reliable, offlineable cache for npmd

add a context menu to patch{bay,work}

wrappers to make pull-streams useful.

quote and unquote strings. escapes internal quotes and slashes. Automatically decides whether to use single or double quotes.

convert a partial url into an absolute url from your current location.

check if a string is within a range

append stuff to a log. It's important that we can reason about the order, so do not perform parallel writes.

exports encoding/decoding functions for flumedb.

Validation library for muxrpc apis

callback when all callbacks have fired.

bandwidth efficient broadcast gossip

color in your node.js console, without monkeypatching

construct a pull-stream for reading from a writable source, can read old records, new (live) records, or both.

read from one pull-stream, then the next, then the next...

a simple benchmark of flumedb log implementations.

Streams to make test other Streams