zerobias

//@flow

declare function deepSeq<P>(
  ...path: P
): $TupleMap<P, <T, Prop>(prop: Prop) => T => $ElementType<T, Prop>>

    
declare var pipe: $ComposeReverse

const target: 'target' = 'target'

zerobias

export function Do(generatorFunction) {
  const generator = generatorFunction()

  return function next(error, v) {
    const res = generator.next(v)

    if (res.done)
      return res.value
    else

zerobias

declare module 'redux-act' {
  
  /**
   * Single "action" as it referenced from classic redux
   * @typedef {{ type: string, payload: P }} Act.<P>
   * @template P
   */
  declare export
  type Act</*::+*/P = mixed> = {

zerobias

declare module 'fs-extra' {
  import type {
    createReadStream as createReadStreamType,
    createWriteStream as createWriteStreamType,
  } from 'fs'

  declare export var createReadStream: $PropertyType<
    $Exports<'fs'>,
    'createReadStream',
  >

zerobias

import {Stream, fromPromise} from 'most'
import {message, effect, Effect, Message} from 'effector'

type State = {
  currentUser: number,
}

/**
 * Plain async function
 */

zerobias

[options]
module.name_mapper='^most-subject$' -> '<PROJECT_ROOT>/most-subject'

zerobias

//@flow

export type SeedValue<S, V> = {
  seed: S,
  value: V,
}
export type TimeValue<V> = {
  /*::+*/time: number,
  /*::+*/value: V
}

zerobias

//@flow

import type {Stream} from 'most'

function intoAsync<T>(str: Stream<T>): $AsyncIterable<T, void, any> {
  let isEnd = false
  let ask: Array<Dispose<T>> = []
  let tell: Array<T> = []
  const end = str.observe(t => {
    if (ask.length > 0) {

zerobias

//@flow

import {
  ping,
  submitLogin,
  requestAuth,
  showNotification,
} from './events'

import type {State} from './state'

zerobias

parser: babel-eslint
parserOptions:
  ecmaVersion: 8
  ecmaFeatures:
    experimentalObjectRestSpread: true
extends:
  - 'plugin:flowtype/recommended'
plugins:
  - babel
  - flowtype