Skip to content

Instantly share code, notes, and snippets.

View juliangruber's full-sized avatar

Julian Gruber juliangruber

1.6k followers · 219 following
View GitHub Profile
@juliangruber
juliangruber / oops2.js
Created January 26, 2018 10:50
const fs = require('fs')
const hyperdrive = require('hyperdrive')
const src = `/tmp/${Math.random()}/`
console.log(src)
const storage = require('dat-storage')(src)
const archive = hyperdrive(storage, { latest: true, indexing: true })
archive.writeFile('/dat.json', 'hi', err => {
if (err) throw err
@juliangruber
juliangruber / oops.js
Created January 26, 2018 10:19
const fs = require('fs')
const src = `/tmp/${Math.random()}`
Dat(src, (err, dat) => {
if (err) throw err
dat.archive.writeFile('/dat.json', 'hi', err => {
if (err) throw err
console.log(fs.readFileSync(`${src}/dat.json`)) // => empty
dat.archive.readFile('/dat.json', (err, data) => {
@juliangruber
juliangruber / 01-results.md
Last active January 15, 2018 11:16
benchmark: pull-stream vs async-stream 
$ node bench-01-pull-stream.js
pull3*100000: 1995.798ms
pull_compose*100000: 1968.901ms
pull_chain*100000: 1871.930ms

$ node bench-02-async-stream.js
async3*100000: 3295.666ms
async3*100000: 3145.636ms
async3*100000: 2943.988ms
@juliangruber
juliangruber / async-heap.js
Last active January 4, 2018 08:30 — forked from dominictarr/output.txt
// https://github.com/juliangruber/async-stream
function heap (name, Stream) {
var start = Date.now()
var heap = process.memoryUsage().heapUsed
var a = [], N = 100000
for(var i = 0; i < N; i++)
a.push(Stream())
console.log(name, (process.memoryUsage().heapUsed - heap)/N, (Date.now()-start))
a = null
@juliangruber
juliangruber / gist:fe383095909a9e237c11a5318262920b
Last active August 7, 2017 20:24
const writeToRemote = new PassThrough()
reconnect(async con => {
await sendState(con)
writeToRemote.pipe(con)
}).on('disconnect', () => {
writeToRemote.unpipe()
})
theRestOfYourProgram.pipe(writeToRemote)
@juliangruber
juliangruber / gist:5118694
Created March 8, 2013 18:34
node.js domain example with event emitters
var domain = require('domain');
var EventEmitter = require('events').EventEmitter;
var inner = function (ee1, ee2, cb1, cb2) {
var domain1 = domain.createDomain();
domain1.on('error', function (err) {
domain1.dispose();
cb2();
@juliangruber
juliangruber / index.js
Created August 18, 2013 23:49
requirebin sketch
var Rating = require('rating');
var insertCSS = require('insert-css');
insertCSS('.star { color: gray } .star.glow { color: brown }');
var rating = new Rating([1, 2, 3, 4, 5]);
document.body.appendChild(rating.el);
var current = document.createElement('p');
document.body.appendChild(current);
@juliangruber
juliangruber / random-access-directory.js
Created March 5, 2017 13:29
var rad = require('random-access-directory')
var store = rad(procss.env.HOME + '/.dat/')
// create a first store
store = store('hypercore.txt')
store.get(0, ...)
// create another store, based on the first one
// this way modules can pass the store instance
@juliangruber
juliangruber / hypercore-index.js
Created September 28, 2016 14:04
index(feed, {
start: 0,
end: Infinity,
key: feed.key
}, function onentry (entry, cb) {
cb()
}, function ondone () {
@juliangruber
juliangruber / interactive-execution.js
Created September 28, 2016 09:48
const http = require('http')
http.createServer((req, res) => {
res.write('<!DOCTYPE html><html><head><title>electron-stream</title><script>')
res.write('console.log("hi");\n')
setTimeout(() => {
res.write('console.log("you");\n')
res.end('</script></head></html>')
}, 3000)
}).listen(8000, () => console.log('8000'))