rkatic

/** @param {number} n */
function semaphore (n) {
  const resolvers = []
  const pushToResolvers = resolve => { resolvers.push(resolve) }

  /** @type {() => (Promise<void> | void)} */
  const acquire = () => {
    if (--n < 0) {

rkatic

const identity = x => x

/**
 * Creates a predicate function to check if a value is not seen before
 *
 * @param {function} [by = x=>x]
 * @returns {function} predicate function
 *
 * @example
 *

rkatic

'use strict'

const objToStringMethod = Object.prototype.toString
const reRegExpChar = /[\\^$.*+?()[\]{}|]/g
const reUnescapedSpaces = /(?<!\\)\s+/g
const reHasSpace = /\s/

const compact = raw => reHasSpace.test(raw) ? raw.replace(reUnescapedSpaces, '') : raw
const escape = val => String(val).replace(reRegExpChar, '\\$&')

rkatic

function timeout (ms, x) {
  return new Promise((resolve, reject) => {
    let timeoutId = setTimeout(() => {
      timeoutId = null
      reject('timeout')
    }, ms)

    const onSettle = () => {
      if (timeoutId != null) {
        clearTimeout(timeoutId)