Kamisama666

/*
Listens to an EventEmitter and reduces the data returned. The EventEmitter must at least three types of events:
- dataEvent: it sends the data to be reduced
- endEvent: it signals the completion of the operation
- errorEvent: it sends an error. The operation is interrupted to handle it
*/
function reduceEventEmmitter({dataEvent, endEvent, errorEvent = null}, accumulator = [], reducer, eventEmitter, cb) {
    eventEmitter.on(dataEvent, function handleDataEvent(data) {
        accumulator = reducer(accumulator, data);
    });

Kamisama666

const async = require('async');
const pg = require('pg')

// QueryConnect: (QuerySource, Callback) -> Connection
// QueryDisconnect: Connection -> Connection
// getSmartQuery : (QueryConnect, QueryDisconnect, QuerySource) -> SmartQuery
function getSmartQuery(connect, disconnect, querySource) {
    let conn = null;

    function connectClient(query, _connectClient) {

Kamisama666

const unique = list => list.filter((value, index, list) => list.indexOf(value) === index);

const sortNumber = (a, b) => a - b;

const expandBlock = (accum, block) => {
  if (block.indexOf('-') === -1) {
    accum.push(parseInt(block));
    return accum;
  }

Kamisama666

const searchedBookShelf = originalBooks.reduce((searchedBook, originalBook) => {
  if (originalBook.id === bookOnShelf.id) {
    return originalBook.shelf;
  }

  return searchedBook;
}, null);

Kamisama666

const Q = require('q');

/**
 * Method to reduce observable to a promise.
 *
 * @param observable
 */
function reduceToPromise(observable) {
    return observable.reduce((acc, item) => [...acc, item], [])
        .toPromise(Q.Promise);

Kamisama666

const fn = require('fn.js');

const has = fn.curry(function(key, object) {
    if (!object[key]) {
        throw new Error(`Missing key '${key}' on object`);
    }

    return object;
})

Kamisama666

const fn = require('fn.js');

const or = fn.curry((defaultValue, value) => value ? value : defaultValue);

Kamisama666

const Rx = require('rx');

getPages(5, 1)
    .then(reduceToPromise)
    .then(console.log)

function getPages(perPage, page) {
    return new Promise(function(resolve, reject) {
        resolve(getAllPages(perPage, page));
    });

Kamisama666

const Q = require('q');

/**
 * Transforms a Q Promise to a Promise
 * @param  {QPromise} qpromise
 * @return {Promise}
 */
function qp(qpromise) {
    return new Promise(function(resolve, reject) {
        qpromise

Kamisama666

"use strict";
const Q = require('q');
const fn = require('fn.js');

// Maps a function that returns a promise and then passes that array of promises to Q.all so they are all processed
const mapAll = fn.curry(fn.compose(Q.all, fn.map), 2);

// Returns a promise
function returnPromise(something) {
    return Q().then(() => something);