mgtitimoli

// @flow

type CancellablePromise<Result> = {
  promise: Promise<Result>,
  cancel: (reason?: string) => void
};

// $FlowFixMe: can not add custom properties to Error
const setCancelled = (error, cancelled) => Object.assign(error, {cancelled});

mgtitimoli

allprojects {
  ext {
    buildTools = "27.0.3"
    compileSdk = 27
    googlePlayServicesVersion = "11.8.0"
    minSdk = 16
    targetSdk = 23
  }

  configurations.all {

mgtitimoli

// @flow

import {curry} from "flow-static-land/lib/Fun";

import type {ComponentType, ElementRef} from "react";

type State = Object;

type Updater<Props: Object> = (prevState: State, props: Props) => State;

mgtitimoli

import createDeferred from "./createDeferred";

const awaitTimeout = (miliseconds, onTimeout) => {
  const deferred = createDeferred();

  const timeoutId = setTimeout(
    () => onTimeout(deferred.resolve, deferred.reject),
    miliseconds
  );

mgtitimoli

// @flow

import shallowEqual from "../shallowEqual";

type OnPropsChanged<Props> = (
  props: Props,
  component: React$Component<*, Props, *>
) => mixed;

const updateIfPropsChanged = <Props: Object, State: void | Object>(

mgtitimoli

const {hasOwnProperty} = Object.prototype;

const isObject = thing => thing !== null && typeof thing === "object";

const objectContains = (object, otherObject) => {
  const objectIsArray = Array.isArray(object);

  const otherObjectIsArray = Array.isArray(otherObject);

  if (objectIsArray && !otherObjectIsArray) {

mgtitimoli

// @flow

import mapValues from 'lodash/fp/mapValues';

type Config = {
  allowed?: Array<string>
};

type ListenerRelatedMethod = (eventName: string, listener: Function) => void;

mgtitimoli

// API:
//
// Promise.prototype.cancel(...args):
//     | Promise<resolved> // if promise was cancellable and no error happened
//     | Promise<rejected> // if promise was not cancellable or some error happened
//
// type CancellationHandler = (...args) =>
//     | Promise<rejected> // can be returned manually or automatically generated by throwing an error
//     | Promise<resolved> // can be returned manually or returning without throwing an error
//

mgtitimoli

import compose from "lodash/fp/compose";
import curry from "lodash/fp/curry";

const mappableWith = curry((compose, apply) => Object.assign(
    map => mappableWith(compose, compose(map, apply)),
    {valueOf: () => apply()}
));

const mappable = mappableWith(compose);

mgtitimoli

import createCancellationToken from './createCancellationToken';

export default class AsyncQueue {
  process = createCancellationToken()

  _tasks = [];

  enqueue(...newTasks) {
    this._tasks.push(...newTasks);