style(core): use prettify to formating

Author: tusharmath

benchmarks/bm.combine.ts

@@ -13,14 +13,10 @@ const c = array(1e2)
 const sum3 = (a: number, b: number, c: number) => a + b + c
 const sum2 = (a: number, b: number) => a + b
 
-export function bm_fromArray_combine (suite: Suite) {
-  return suite
-    .add(
-      'file -> combine(sum3, [a, b, c]) -> reduce(sum2, 0)',
-      (d: IDeferred) => run(
-        reduce(sum2, 0, combine(sum3, [fromArray(a), fromArray(b), fromArray(c)])),
-        d
-      ),
-      {defer: true}
-    )
+export function bm_fromArray_combine(suite: Suite) {
+  return suite.add(
+    'file -> combine(sum3, [a, b, c]) -> reduce(sum2, 0)',
+    (d: IDeferred) => run(reduce(sum2, 0, combine(sum3, [fromArray(a), fromArray(b), fromArray(c)])), d),
+    {defer: true}
+  )
 }

benchmarks/bm.create.ts

@@ -6,17 +6,13 @@ import {IObserver} from '../src/lib/Observer'
 import {create} from '../src/sources/Create'
 import {IDeferred, run} from './lib'
 
-function subscriber (observer: IObserver<number>) {
+function subscriber(observer: IObserver<number>) {
   for (var i = 0; i < 1e6; ++i) {
     observer.next(i)
   }
   observer.complete()
 }
 
-export function bm_create (suite: Suite) {
-  return suite.add(
-    'create',
-    (d: IDeferred) => run(create(subscriber), d),
-    {defer: true}
-  )
+export function bm_create(suite: Suite) {
+  return suite.add('create', (d: IDeferred) => run(create(subscriber), d), {defer: true})
 }

benchmarks/bm.debounce.ts

@@ -7,10 +7,6 @@ import {fromArray} from '../src/sources/FromArray'
 import {array, IDeferred, run} from './lib'
 
 const a = array(1e3)
-export function bm_debounce (suite: Suite) {
-  return suite.add(
-    'file -> debounce',
-    (d: IDeferred) => run(debounce(100, fromArray(a)), d),
-    {defer: true}
-  )
+export function bm_debounce(suite: Suite) {
+  return suite.add('file -> debounce', (d: IDeferred) => run(debounce(100, fromArray(a)), d), {defer: true})
 }

benchmarks/bm.fromArray-map-reduce.ts

@@ -2,7 +2,6 @@
  * Created by tushar.mathur on 05/11/16.
  */
 
-
 import {Suite} from 'benchmark'
 import {filter} from '../src/operators/Filter'
 import {map} from '../src/operators/Map'
@@ -11,7 +10,7 @@ import {fromArray} from '../src/sources/FromArray'
 import {add1, array, even, IDeferred, run, sum} from './lib'
 
 const a = array(1e6)
-export function bm_fromArray_map_reduce (suite: Suite) {
+export function bm_fromArray_map_reduce(suite: Suite) {
   return suite.add(
     'file -> map -> reduce',
     (d: IDeferred) => run(reduce(sum, 0, map(add1, filter(even, fromArray(a)))), d),

benchmarks/bm.fromArray-scan-reduce.ts

@@ -2,15 +2,14 @@
  * Created by tushar.mathur on 05/11/16.
  */
 
-
 import {Suite} from 'benchmark'
 import {reduce} from '../src/operators/Reduce'
 import {scan} from '../src/operators/Scan'
 import {fromArray} from '../src/sources/FromArray'
 import {array, IDeferred, passthrough, run, sum} from './lib'
 
 const a = array(1e6)
-export function bm_fromArray_scan_reduce (suite: Suite) {
+export function bm_fromArray_scan_reduce(suite: Suite) {
   return suite.add(
     'file -> scan -> reduce',
     (d: IDeferred) => run(reduce(passthrough, 0, scan(sum, 0, fromArray(a))), d),

benchmarks/bm.fromArray-takeN.ts

@@ -8,11 +8,6 @@ import {fromArray} from '../src/sources/FromArray'
 import {array, IDeferred, run} from './lib'
 
 const a = array(1e6)
-export function bm_fromArray_takeN (suite: Suite) {
-  return suite
-    .add(
-      'file -> takeN(0, n/10)',
-      (d: IDeferred) => run(slice(0, 1e6 / 10, fromArray(a)), d),
-      {defer: true}
-    )
+export function bm_fromArray_takeN(suite: Suite) {
+  return suite.add('file -> takeN(0, n/10)', (d: IDeferred) => run(slice(0, 1e6 / 10, fromArray(a)), d), {defer: true})
 }

benchmarks/bm.switch.ts

@@ -9,10 +9,10 @@ import {array, IDeferred, run} from './lib'
 
 const a = array(1e2)
 
-export function bm_switch (suite: Suite) {
+export function bm_switch(suite: Suite) {
   return suite.add(
     'array(2) -> array(i) -> switchLatest',
-    (d: IDeferred) => run(switchLatest(map((i) => fromArray(array(i)), fromArray(a))), d),
+    (d: IDeferred) => run(switchLatest(map(i => fromArray(array(i)), fromArray(a))), d),
     {defer: true}
   )
 }

benchmarks/bm.tryCatch.ts

@@ -5,7 +5,7 @@ import {Suite} from 'benchmark'
 import {ISafeValue, tryCatch} from '../src/lib/Utils'
 import {array} from './lib'
 
-function addThis (b: number) {
+function addThis(b: number) {
   this.a = this.a + b
   if (this.a % 2 === 0) {
     throw 'ERROR'
@@ -14,14 +14,14 @@ function addThis (b: number) {
 }
 const safelyAddThis = tryCatch(addThis)
 
-export function testFunction (arr: number[]): Array<ISafeValue<any>> {
+export function testFunction(arr: number[]): Array<ISafeValue<any>> {
   const results = []
   for (var i = 0; i < arr.length; ++i) {
     results.push(safelyAddThis.call({a: 100}, i))
   }
   return results
 }
 const arr = array(1e3)
-export function bm_tryCatch (suite: Suite) {
+export function bm_tryCatch(suite: Suite) {
   return suite.add('tryCatch', () => testFunction(arr))
 }

benchmarks/lib.ts

@@ -6,50 +6,46 @@ import {createScheduler, IScheduler} from '../src/lib/Scheduler'
  * Created by tushar.mathur on 05/11/16.
  */
 
-
 const Table = require('cli-table2')
 
-
 export interface IDeferred {
-  resolve (): void
+  resolve(): void
 }
-export function add1 (x: number) {
+export function add1(x: number) {
   return x + 1
 }
-export function even (e: number) {
+export function even(e: number) {
   return e % 2 === 0
 }
-export function sum (a: number, b: number) {
+export function sum(a: number, b: number) {
   return a + b
 }
 
-export function passthrough (z: any, x: any) {
+export function passthrough(z: any, x: any) {
   return x
 }
 
 export const scheduler = createScheduler() as IScheduler
 
 class BmObserver<T> implements IObserver<T> {
-  constructor (private d: IDeferred) {}
+  constructor(private d: IDeferred) {}
 
-  next (val: T): void {
-  }
+  next(val: T): void {}
 
-  error (err: Error): void {
+  error(err: Error): void {
     throw err
   }
 
-  complete (): void {
+  complete(): void {
     this.d.resolve()
   }
 }
 
-export function run (observable: IObservable<any>, d: IDeferred) {
-  observable.subscribe(new BmObserver(d), scheduler
-  )
+export function run(observable: IObservable<any>, d: IDeferred) {
+  observable.subscribe(new BmObserver(d), scheduler)
 }
 
-export function array (n: number) {
+export function array(n: number) {
   const a = new Array(n)
   for (var i = 0; i < a.length; ++i) {
     a[i] = i
@@ -66,7 +62,7 @@ export const onCycle = (event: any) => {
   table.push([
     target.name,
     `${Math.floor(target.hz).toLocaleString()} (±${Math.round(target.stats.rme * 100) / 100}%)`,
-    target.stats.sample.length,
+    target.stats.sample.length
   ])
 }
 
@@ -75,4 +71,3 @@ export const onEnd = () => {
   console.log(table.toString())
   console.log('```')
 }
-

benchmarks/run.ts

@@ -26,7 +26,4 @@ bm_fromArray_scan_reduce(suite)
 bm_fromArray_takeN(suite)
 bm_switch(suite)
 bm_tryCatch(suite)
-suite
-  .on('cycle', onCycle)
-  .on('complete', onEnd)
-  .run()
+suite.on('cycle', onCycle).on('complete', onEnd).run()

package.json

@@ -14,7 +14,8 @@
     "test": "tsc && ava",
     "test:watch": "ava --watch",
     "build": "rollup -c ./config/rollup.config.js",
-    "lint": "git ls-files | grep '.ts$' | xargs tslint"
+    "lint": "git ls-files | grep '.ts$' | xargs tslint",
+    "prettify": "git ls-files | grep '.ts$' | xargs prettier --print-width 120 --write --single-quote --no-semi --no-bracket-spacing"
   },
   "author": "",
   "license": "ISC",
@@ -28,6 +29,7 @@
     "gh-pages": "^1.0.0",
     "ghooks": "^2.0.0",
     "nyc": "^10.0.0",
+    "prettify": "^0.1.7",
     "request-promise": "^4.1.1",
     "rollup": "^0.41.2",
     "rollup-plugin-babili": "^3.0.0",

src/lib/Container.ts

@@ -2,9 +2,13 @@
  * Created by tushar on 08/12/16.
  */
 
-export enum StreamStatus { IDLE, STARTED, COMPLETED }
+export enum StreamStatus {
+  IDLE,
+  STARTED,
+  COMPLETED
+}
 
-export function createArray<T> (size: number, value: T) {
+export function createArray<T>(size: number, value: T) {
   const arr: Array<T> = new Array(size)
   for (var i = 0; i < size; ++i) {
     arr[i] = value
@@ -13,7 +17,7 @@ export function createArray<T> (size: number, value: T) {
 }
 
 export interface IContainer {
-  next<T> (value: T, id: number): void
+  next<T>(value: T, id: number): void
   complete(id: number): boolean
   isDone(): boolean
   isOn(): boolean
@@ -26,30 +30,29 @@ class ValueContainer implements IContainer {
   private started = 0
   private completed = 0
 
-  constructor (private total: number) {
-  }
+  constructor(private total: number) {}
 
-  next (value: any, id: number) {
+  next(value: any, id: number) {
     if (this.status[id] === StreamStatus.IDLE) {
       this.status[id] = StreamStatus.STARTED
       this.started++
     }
     this.values[id] = value
   }
 
-  complete (id: number) {
+  complete(id: number) {
     if (this.status[id] !== StreamStatus.COMPLETED) {
       this.status[id] = StreamStatus.COMPLETED
       this.completed++
     }
     return this.isDone()
   }
 
-  isDone () {
+  isDone() {
     return this.completed === this.total
   }
 
-  isOn () {
+  isOn() {
     return this.started === this.total
   }
 }

src/lib/ForEach.ts

@@ -10,18 +10,19 @@ export type TOnNext<T> = {(value: T): void}
 export type TSource<T> = IObservable<T>
 export type TResult = ISubscription
 
-export const forEach = curry(function <T> (onNext: TOnNext<T>, observable: TSource<T>) {
-  return observable.subscribe({
-    next (value: T) {
-      onNext(value)
+export const forEach = curry(function<T>(onNext: TOnNext<T>, observable: TSource<T>) {
+  return observable.subscribe(
+    {
+      next(value: T) {
+        onNext(value)
+      },
+      complete() {},
+      error(err: Error) {
+        throw err
+      }
     },
-    complete() {
-    },
-    error (err: Error) {
-      throw err
-    }
-  }, createScheduler())
-}) as Function &
-  {<T> (onNext: TOnNext<T>, source: TSource<T>): TResult} &
-  {<T> (onNext: TOnNext<T>): {(source: TSource<T>): TResult}}
-
+    createScheduler()
+  )
+}) as Function & {<T>(onNext: TOnNext<T>, source: TSource<T>): TResult} & {
+    <T>(onNext: TOnNext<T>): {(source: TSource<T>): TResult}
+  }