ccnokes

/**
 * make an async function take at least X amount of time
 * @param limit - in ms
 * @param fn - returns promise
 * @returns {Promise.<T>}
 */
function waitAtLeast(limit, fn) {
	let start = Date.now();
	let end = start + limit;

ccnokes

// throughput is usually ~350-400 MiB/s
// run: node yes.js | pv > /dev/null

const buf = Buffer.alloc(4096, 'y\n', 'utf8');
const str = buf.toString();
const { Readable } = require('stream');

class Y extends Readable {
  _read() {
    this.push(str);

ccnokes

function randomErrorObs() {
  return Rx.Observable.create(obs => {
    let n = 0;
    if(Math.random() < 0.5) {
      obs.next(++n);
    } else {
      console.warn('producing error');
      obs.error('bummer');
    }
  });

ccnokes

import { EventEmitter } from 'events';

const enum Actions {
  get,
  set,
  delete
}

export class Store extends EventEmitter {
  private data = new Map<string, any>();

ccnokes

// this will cache the response indefinitely in a cache created via $cacheFactory
// that cache is shared globally among all $http requests
$http.get('http://pokeapi.co/api/v2/pokemon/1/', {
  cache: true
});

ccnokes

// This class implements the same interface that the cache created by $cacheFactory does
// See https://github.com/angular/angular.js/blob/master/src/ng/cacheFactory.js#L142
// This cache evicts an entry once it's expired (which we define as 5 seconds).
class ExpirationCache {
  constructor(timeout = 5000) {
    this.store = new Map();
    this.timeout = timeout;
  }
  
  get(key) {

ccnokes

// create an LRU (least recently used) cache with up to 10 entries
const lru = $cacheFactory('my-cache', { capacity: 10 });

$http.get('http://pokeapi.co/api/v2/pokemon/1/', {
  cache: lru
});

ccnokes

function makeLazy(name, fn, obj = {}) {
  const nullSym = Symbol('nil'); //could change this to be more es5 friendly
  let val = nullSym; //I'm not sure if holding the value in this closure or right on the object is better

  Object.defineProperty(obj, name, {
    enumerable: true,
    get() {
      if(val === nullSym) {
        val = fn();

ccnokes

function iterate(iterator, cb) {
  let next = iterator.next();
  while(!next.done) {
    cb(next.value);
    next = iterator.next();
  }
}

// iterate(new Set([1,2,3]).values(), console.log)

ccnokes

function makeAbortablePromise(promise, abort = () => {}) {
  const promiseWithAbort = {
    abort,
    promise,
    // proxy methods
    then: (...args) => {
      promiseWithAbort.promise = promiseWithAbort.promise.then.apply(
        promiseWithAbort.promise,
        args
      );