Merge pull request #28 from tusharmath/currying

Currying

src/lib/Curry.ts

@@ -0,0 +1,14 @@
+/**
+ * Created by tushar.mathur on 15/10/16.
+ */
+
+
+import {ICurryFunction} from '../types/ICurryFunction'
+
+export function Curry <T, R> (f: ICurryFunction<T>): ICurryFunction<T> {
+  return function curried (...t: any[]): T | ICurryFunction<T> {
+    if (t.length === 0) return curried
+    if (t.length === f.length) return f(...t)
+    return curried.bind(this, ...t)
+  }
+}

src/main.ts

@@ -6,15 +6,28 @@
 export {Observer} from './lib/Observer'
 
 // Operators
-export {filter} from './operators/Filter'
-export {join} from './operators/Join'
-export {map} from './operators/Map'
-export {scan} from './operators/Scan'
-export {slice} from './operators/Slice'
-export {tap} from './operators/Tap'
-export {reduce} from './operators/Reduce'
+import {filter as _filter} from './operators/Filter'
+import {join as _join} from './operators/Join'
+import {map as _map} from './operators/Map'
+import {scan as _scan} from './operators/Scan'
+import {slice as _slice} from './operators/Slice'
+import {tap as _tap} from './operators/Tap'
+import {reduce as _reduce} from './operators/Reduce'
 
 // Sources
-export {fromArray} from './sources/FromArray'
-export {interval} from './sources/Interval'
-export {fromDOM} from './sources/FromDOM'
+import {fromArray as _fromArray} from './sources/FromArray'
+import {interval as _interval} from './sources/Interval'
+import {fromDOM as _fromDOM} from './sources/FromDOM'
+import {Curry} from './lib/Curry'
+
+
+export const filter = Curry(_filter)
+export const join = Curry(_join)
+export const map = Curry(_map)
+export const scan = Curry(_scan)
+export const slice = Curry(_slice)
+export const tap = Curry(_tap)
+export const reduce = Curry(_reduce)
+export const fromArray = Curry(_fromArray)
+export const interval = Curry(_interval)
+export const fromDOM = Curry(_fromDOM)

src/types/ICurryFunction.ts

@@ -0,0 +1,7 @@
+/**
+ * Created by tushar.mathur on 15/10/16.
+ */
+
+export interface ICurryFunction<T> {
+  (...k: any[]): T | ICurryFunction<T>
+}

test/test.Curry.ts

@@ -0,0 +1,28 @@
+/**
+ * Created by tushar.mathur on 15/10/16.
+ */
+
+import test from 'ava'
+import {Curry} from '../src/lib/Curry'
+import {ICurryFunction} from '../src/types/ICurryFunction'
+
+const func = Curry<number[], number>(
+  (a: number, b: number, c: number) => [a, b, c]
+)
+
+
+test('func(1, 2, 3)', t => {
+  t.deepEqual(func(1, 2, 3), [1, 2, 3])
+})
+
+test('func(1, 2)(3)', t => {
+  const func2 = func(1, 2) as ICurryFunction<number[]>
+  t.deepEqual(func2(3), [1, 2, 3])
+})
+
+test('func(1)(2)(3)', t => {
+  t.deepEqual((
+      (func(1) as ICurryFunction<number[]>)(2) as ICurryFunction<number[]>)(3),
+    [1, 2, 3]
+  )
+})

test/test.FromArray.ts

@@ -5,9 +5,10 @@
 'use strict'
 
 import test from 'ava'
-import {fromArray, map} from '../src/main'
 import {TestScheduler} from '../src/testing/TestScheduler'
 import {ReactiveEvents} from '../src/testing/ReactiveEvents'
+import {map} from '../src/operators/Map'
+import {fromArray} from '../src/sources/FromArray'
 
 const {next, error} = ReactiveEvents
 test(t => {

test/test.IntervalObservable.ts

@@ -5,10 +5,10 @@
 'use strict'
 
 import test from 'ava'
-import {interval} from '../src/main'
 import {TestScheduler} from '../src/testing/TestScheduler'
 import {ReactiveEvents, EventError} from '../src/testing/ReactiveEvents'
 import {IEvent} from '../src/types/IEvent'
+import {interval} from '../src/sources/Interval'
 const {next, error} = ReactiveEvents
 
 test('subscribe()', t => {

test/test.JoinObservable.ts

@@ -3,9 +3,9 @@
  */
 
 import test from 'ava'
-import {join} from '../src/main'
 import {TestScheduler} from '../src/testing/TestScheduler'
 import {ReactiveEvents} from '../src/testing/ReactiveEvents'
+import {join} from '../src/operators/Join'
 const {next, complete} = ReactiveEvents
 
 test('subscribe()', t => {

test/test.MapObservable.ts

@@ -5,9 +5,9 @@
 'use strict'
 
 import test from 'ava'
-import {map} from '../src/main'
 import {TestScheduler} from '../src/testing/TestScheduler'
 import {ReactiveEvents} from '../src/testing/ReactiveEvents'
+import {map} from '../src/operators/Map'
 
 const {next, complete} = ReactiveEvents
 

test/test.ScanObservable.ts

@@ -3,9 +3,9 @@
  */
 
 import test from 'ava'
-import {scan} from '../src/main'
 import {TestScheduler} from '../src/testing/TestScheduler'
 import {ReactiveEvents} from '../src/testing/ReactiveEvents'
+import {scan} from '../src/operators/Scan'
 
 const {next, complete} = ReactiveEvents
 

test/test.SliceObservable.ts

@@ -6,8 +6,8 @@
 
 import test from 'ava'
 import {TestScheduler} from '../src/testing/TestScheduler'
-import {slice} from '../src/main'
 import {ReactiveEvents} from '../src/testing/ReactiveEvents'
+import {slice} from '../src/operators/Slice'
 
 const {next, complete} = ReactiveEvents
 test('takeN(0, 3)', t => {