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

const axios = require('axios');
const http = require('http');
const https = require('https');

module.exports = axios.create({
  //60 sec timeout
  timeout: 60000,

  //keepAlive pools and reuses TCP connections, so it's faster
  httpAgent: new http.Agent({ keepAlive: 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

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

// 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 objToParams(obj) {
  const params = new URLSearchParams();
  for(let key in obj) {
    if(Array.isArray(obj[key])) {
      obj[key].forEach(item => params.append(key, item));
    } 
    else if(typeof obj[key] === 'object') {
      continue;
    }
    else {

ccnokes

import * as _ from 'lodash';

let n = 2;
let someString;

// NOTE `_.pickBy(params, _.negate(_.isNil))` removes undefined/null entries
// so you don't have to worry about `undefined` getting coerced to a string
const formatUrl = (urlStr, params) => urlStr + '?' + 
      new URLSearchParams(_.pickBy(params, _.negate(_.isNil))).toString();