DanShappir

const myButton = document.getElementById("myButton");
pipe(
  fromEvent(myButton, "click"),
  reduce(acc => acc + 1, 0),
  forEach(count => console.log(count))
);

DanShappir

function forEach(op) {
  return async function (src) {
    let index = 0;
    for await (const value of src) {
      if (op(value, index++) === false) {
        break;
      }
    }
  };
}

DanShappir

async function forEach(src, op) {
  let index = 0;
  for await (const value of src) {
    if (op(value, index++) === false) {
      break;
    }
  }
}

DanShappir

const myButton = document.getElementById("myButton");
fromEvent(myButton, "click")
  |> reduce(#, acc => acc + 1, 0)
  |> forEach(#, count => console.log(count));

DanShappir

function filter(op) {
  return function* (src) {
    for (const value of src) {
      if (op(value)) {
        yield value;
      }
    }
  };
}

DanShappir

function* filter(src, op) {
  for (const value of src) {
    if (op(value)) {
      yield value;
    }
  }
}

DanShappir

const result = pipe(
  numbers,
  filter(v => v % 2 == 0),
  map(v => v + 1),
  slice(0, 3),
  Array.from
);

DanShappir

function pipe(arg, ...fns) {
  return fns.reduce((v, fn) => fn(v), arg);
}

DanShappir

const result = numbers
  |> filter(#, v => v % 2 === 0)
  |> map(#, v => v + 1)
  |> slice(#, 0, 3)
  |> Array.from;

DanShappir

const result = Array.from(slice(map(filter(numbers, v => v % 2 === 0), v => v + 1), 0, 3));