gilesbradshaw

Native promise leaks memory with recursion

const cdc = ({ x, start }) => {
  if (x % 5000000 === 0) {
    gc()
    console.log({
      used: process.memoryUsage(),
      x,
      time: Date.now() - start,

gilesbradshaw

import mssql, { Request } from 'mssql'
import colors from 'colors'
import config from 'config'
import squel from 'squel'

const squelMssql = squel.useFlavour('mssql')

// import configurationStreams from './kafka/configuration'
// import runtimeStreams from './kafka/runtime'

gilesbradshaw

given

const compose = (...functions) =>
  (...params) =>
    functions
      .reduce(
        (acc, func) => [func(...acc)],
        params,
      )[0]

gilesbradshaw

export default (...functions) =>
  param =>
    functions
      .reduce(
        (acc, func) => func(acc),
        param,
      )

gilesbradshaw

// serialises access to an action
export default () => {
  // promise to allow the next action
  let next = Promise.resolve()
  return (action) => {
    let nextResolve
    const nextNext = () => new Promise(
      (resolve, reject) =>
        action()
          .then(

gilesbradshaw

"use strict";
/**
 * @module opcua.server
 *
 */


const assert = require("node-opcua-assert").assert;
const _ = require("underscore");

gilesbradshaw

// a reduce function for a generator
// the result of the reducer function gets passed into next
function reduce(
  reducer,
  seed,
) {
  const gen = this(seed);
  let acc = seed;
  let results = [];
  let next = gen.next();

gilesbradshaw

import { marbles } from 'rxjs-marbles';

/* eslint-env mocha */
/* eslint-disable no-unused-expressions */


describe('merge scan', () => {
  it(
    'should work',
    marbles(

gilesbradshaw

var edge = require('edge'); // http://tjanczuk.github.io/edge
var Rx = require('rxjs'); // https://github.com/Reactive-Extensions/RxJS

var createSubject = edge.func({
  // this is c#
  source: function () {/*
    using System.Reactive.Linq;
    using System.Reactive.Subjects;
    using ClassLibrary1;
    async (dynamic input) => {

gilesbradshaw

function map(func) {
  return this.reduce(
    (acc, val) => [
      ...acc
      func(val),
    ],
    [],
  );
}