I hereby claim:
- I am amsross on github.
- I am amsross_side (https://keybase.io/amsross_side) on keybase.
- I have a public key ASALXda8H2gLEfQ5_8oDv-G-bpWP1amx1zkDJsR799Codgo
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
module Infix = BsBastet.Infix; | |
module Interface = BsBastet.Interface; | |
module type Monad = {include Interface.MONAD;}; | |
module type Def = { | |
type m('a); | |
type t('a); | |
include Interface.MONAD with type t('a) := t('a); |
I hereby claim:
To claim this, I am signing this object:
const { warn, info, trace } = require('./logger') | |
const { EventEmitter } = require('events') | |
const h = require('highland') | |
const q = require('request') | |
warn('\nstarting') | |
const rand = (min, max) => Math.ceil(Math.random() * (max - min)) + min | |
const gen = tag => h(push => setInterval(() => { | |
push(null, ([ tag, Date.now() ])) |
const { each, from, through } = require('mississippi') | |
const { internet: { avatar, email, password } } = require('faker') | |
const { pick } = require('ramda') | |
const highWaterMark = 1 | |
const objectMode = true | |
const getUsers = count => from({ objectMode, highWaterMark }, (size, next) => { | |
if (--count < 0) return next(null, null) | |
next(null, { |
console.time('time to pipe') | |
const { createReadStream } = require('fs') | |
const { Socket } = require('net') | |
const { createDeflate } = require('zlib') | |
const through = require('through2') | |
const { argv } = require('yargs') | |
const { fromArray, filter, reject, split } = require('./helpers') | |
const HANDLE = '/tmp/listener.sock' |
const h = require('highland') | |
const putRecord = ip => record => domain => record(ip) | |
.flatMap(record => h.of({ | |
[`/domains/${domain}/records/${record.name}/${record.type}`]: record | |
})) | |
const ips = h([ | |
'127.0.0.1', | |
'10.0.0.1', |