Skip to content

Commit 7fed711

Browse files
tusharmathtusharmath
committed
fix(core): fix typings for all operator
1 parent 93f716c commit 7fed711

File tree

14 files changed

+48
-48
lines changed

14 files changed

+48
-48
lines changed

‎src/lib/ForEach.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,6 @@ export const forEach = curry(function<T>(onNext: TOnNext<T>, observable: TSource
2323
},
2424
createScheduler()
2525
)
26-
}) as Function & {<T>(onNext: TOnNext<T>, source: TSource<T>): TResult} & {
27-
<T>(onNext: TOnNext<T>): {(source: TSource<T>): TResult}
28-
}
26+
}) as {<T>(onNext: TOnNext<T>, source: TSource<T>): TResult} & {
27+
<T>(onNext: TOnNext<T>): {(source: TSource<T>): TResult}
28+
}

‎src/operators/Combine.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,6 @@ class CombineObservable<T> implements IObservable<T> {
6767

6868
export const combine = curry(
6969
<T>(selector: TSelector<T>, sources: IObservable<any>[]) => new CombineObservable(selector, sources)
70-
) as Function & {<T, R>(selector: TSelector<T>, sources: TSource): TResult<R>} & {
71-
<T, R>(selector: TSelector<T>): {(sources: TSource): TResult<R>}
72-
}
70+
) as {<T, R>(selector: TSelector<T>, sources: TSource): TResult<R>} & {
71+
<T, R>(selector: TSelector<T>): {(sources: TSource): TResult<R>}
72+
}

‎src/operators/Debounce.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,8 @@ class Debounce<T> implements IObservable<T> {
4444
}
4545
}
4646

47-
export const debounce = curry(
48-
<T>(timeout: number, source: IObservable<T>) => new Debounce(timeout, source)
49-
) as Function & {<T>(timeout: number, source: IObservable<T>): IObservable<T>} & {
50-
<T>(timeout: number): {(source: IObservable<T>): IObservable<T>}
51-
}
47+
export const debounce = curry(<T>(timeout: number, source: IObservable<T>) => new Debounce(timeout, source)) as {
48+
<T>(timeout: number, source: IObservable<T>): IObservable<T>
49+
} & {
50+
<T>(timeout: number): {(source: IObservable<T>): IObservable<T>}
51+
}

‎src/operators/Delay.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,6 @@ class DelayObservable<T> implements IObservable<T> {
4747

4848
export const delay = curry(
4949
<T>(timeout: number, source: IObservable<T>): IObservable<T> => new DelayObservable(timeout, source)
50-
) as Function & {<T>(timeout: number, source: IObservable<T>): IObservable<T>} & {
51-
<T>(timeout: number): {(source: IObservable<T>): IObservable<T>}
52-
}
50+
) as {<T>(timeout: number, source: IObservable<T>): IObservable<T>} & {
51+
<T>(timeout: number): {(source: IObservable<T>): IObservable<T>}
52+
}

‎src/operators/Filter.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,6 @@ class FilterObservable<T> implements TResult<T> {
3838

3939
export const filter = curry(function<T>(predicate: TPredicate<T>, source: TSource<T>) {
4040
return new FilterObservable(predicate, source)
41-
}) as Function & {<T>(predicate: TPredicate<T>, source: TSource<T>): TResult<T>} & {
42-
<T>(predicate: TPredicate<T>): {(source: TSource<T>): TResult<T>}
43-
}
41+
}) as {<T>(predicate: TPredicate<T>, source: TSource<T>): TResult<T>} & {
42+
<T>(predicate: TPredicate<T>): {(source: TSource<T>): TResult<T>}
43+
}

‎src/operators/Join.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,6 @@ export function join<T>(source: IObservable<IObservable<T>>): IObservable<T> {
7575
}
7676
export const flatMap = curry(<T, K>(fn: (t: K) => IObservable<T>, source: IObservable<K>) => {
7777
return join(map(fn, source))
78-
}) as Function & {<T, K>(mapper: (t: K) => IObservable<T>, source: IObservable<K>): IObservable<T>} & {
79-
<T, K>(mapper: (t: K) => IObservable<T>): {(source: IObservable<K>): IObservable<T>}
80-
}
78+
}) as {<T, K>(mapper: (t: K) => IObservable<T>, source: IObservable<K>): IObservable<T>} & {
79+
<T, K>(mapper: (t: K) => IObservable<T>): {(source: IObservable<K>): IObservable<T>}
80+
}

‎src/operators/Map.ts

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -38,21 +38,21 @@ class MapObservable<T, R> implements TResult<R> {
3838

3939
export const map = curry(function<T, R>(mapFunction: (a: T) => R, source: IObservable<T>) {
4040
return new MapObservable(mapFunction, source)
41-
}) as Function & {<T, R>(mapper: TMapper<T, R>, source: TSource<T>): TResult<R>} & {
42-
<T, R>(mapper: TMapper<T, R>): {(source: TSource<T>): TResult<R>}
43-
}
41+
}) as {<T, R>(mapper: TMapper<T, R>, source: TSource<T>): TResult<R>} & {
42+
<T, R>(mapper: TMapper<T, R>): {(source: TSource<T>): TResult<R>}
43+
}
4444

4545
export const tap = curry(function<T>(mapFunction: (a: T) => void, source: IObservable<T>) {
4646
return new MapObservable((a: T) => {
4747
mapFunction(a)
4848
return a
4949
}, source)
50-
}) as Function & {<T>(mapper: TMapper<T, void>, source: TSource<T>): TResult<void>} & {
51-
<T>(mapper: TMapper<T, void>): {(source: TSource<T>): TResult<void>}
52-
}
50+
}) as {<T>(mapper: TMapper<T, void>, source: TSource<T>): TResult<void>} & {
51+
<T>(mapper: TMapper<T, void>): {(source: TSource<T>): TResult<void>}
52+
}
5353

5454
export const mapTo = curry(function<T extends Function>(mapFunction: T, source: IObservable<T>) {
5555
return new MapObservable(() => mapFunction, source)
56-
}) as Function & {<T>(value: T, source: IObservable<any>): IObservable<T>} & {
57-
<T>(value: T): {(source: IObservable<any>): IObservable<T>}
58-
}
56+
}) as {<T>(value: T, source: IObservable<any>): IObservable<T>} & {
57+
<T>(value: T): {(source: IObservable<any>): IObservable<T>}
58+
}

‎src/operators/Reduce.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -40,8 +40,8 @@ class ReduceObservable<T, R> implements TResult<R> {
4040

4141
export const reduce = curry(function<T, R>(t0: TReducer<T, R>, t1: R, t2: IObservable<T>) {
4242
return new ReduceObservable(t0, t1, t2)
43-
}) as Function & {<T, R>(reducer: TReducer<T, R>, seed: TSeed<R>, source: TSource<T>): TResult<R>} & {
44-
<T, R>(reducer: TReducer<T, R>): {(seed: TSeed<R>, source: TSource<T>): TResult<R>}
45-
} & {<T, R>(reducer: TReducer<T, R>, seed: TSeed<R>): {(source: TSource<T>): TResult<R>}} & {
43+
}) as {<T, R>(reducer: TReducer<T, R>, seed: TSeed<R>, source: TSource<T>): TResult<R>} & {
44+
<T, R>(reducer: TReducer<T, R>): {(seed: TSeed<R>, source: TSource<T>): TResult<R>}
45+
} & {<T, R>(reducer: TReducer<T, R>, seed: TSeed<R>): {(source: TSource<T>): TResult<R>}} & {
4646
<T, R>(reducer: TReducer<T, R>): {(seed: TSeed<R>): {(source: TSource<T>): TResult<R>}}
4747
}

‎src/operators/Sample.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -84,8 +84,8 @@ class SampleObservable<T> implements TResult<T> {
8484

8585
export const sample = curry(function<T>(f: TSelector<T>, sampler: TSampler, sources: TSources) {
8686
return new SampleObservable(f, sampler, sources)
87-
}) as Function & {<T>(selector: TSelector<T>, sampler: TSampler, source: TSources): TResult<T>} & {
88-
<T>(selector: TSelector<T>): {(sampler: TSampler, source: TSources): TResult<T>}
89-
} & {<T>(selector: TSelector<T>, sampler: TSampler): {(source: TSources): TResult<T>}} & {
87+
}) as {<T>(selector: TSelector<T>, sampler: TSampler, source: TSources): TResult<T>} & {
88+
<T>(selector: TSelector<T>): {(sampler: TSampler, source: TSources): TResult<T>}
89+
} & {<T>(selector: TSelector<T>, sampler: TSampler): {(source: TSources): TResult<T>}} & {
9090
<T>(selector: TSelector<T>): {(sampler: TSampler): {(source: TSources): TResult<T>}}
9191
}

‎src/operators/Scan.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -39,8 +39,8 @@ class ScanObservable<T, R> implements TResult<R> {
3939

4040
export const scan = curry(function<T, V>(reducer: TReducer<T, V>, value: V, source: IObservable<T>) {
4141
return new ScanObservable(reducer, value, source)
42-
}) as Function & {<T, R>(reducer: TReducer<T, R>, seed: TSeed<R>, source: TSource<T>): TResult<R>} & {
43-
<T, R>(reducer: TReducer<T, R>): {(seed: TSeed<R>, source: TSource<T>): TResult<R>}
44-
} & {<T, R>(reducer: TReducer<T, R>, seed: TSeed<R>): {(source: TSource<T>): TResult<R>}} & {
42+
}) as {<T, R>(reducer: TReducer<T, R>, seed: TSeed<R>, source: TSource<T>): TResult<R>} & {
43+
<T, R>(reducer: TReducer<T, R>): {(seed: TSeed<R>, source: TSource<T>): TResult<R>}
44+
} & {<T, R>(reducer: TReducer<T, R>, seed: TSeed<R>): {(source: TSource<T>): TResult<R>}} & {
4545
<T, R>(reducer: TReducer<T, R>): {(seed: TSeed<R>): {(source: TSource<T>): TResult<R>}}
4646
}

‎src/operators/SkipRepeats.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,6 @@ class SkipRepeatsObservable<T> implements TResult<T> {
4747

4848
export const skipRepeats = curry(function(hashFunction: TComparator<any>, source: IObservable<any>) {
4949
return new SkipRepeatsObservable(hashFunction, source)
50-
}) as Function & {<T>(cmp: TComparator<T>, source: TSource<T>): TResult<T>} & {
51-
<T>(cmp: TComparator<T>): {(source: TSource<T>): TResult<T>}
52-
}
50+
}) as {<T>(cmp: TComparator<T>, source: TSource<T>): TResult<T>} & {
51+
<T>(cmp: TComparator<T>): {(source: TSource<T>): TResult<T>}
52+
}

‎src/operators/Slice.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -60,8 +60,8 @@ class SliceObservable<T> implements IObservable<T> {
6060

6161
export const slice = curry(function(start: number, count: number, source: IObservable<any>) {
6262
return new SliceObservable(start, count, source)
63-
}) as Function & {<T>(start: number, count: number, source: IObservable<T>): IObservable<T>} & {
64-
<T>(start: number): {(count: number, source: IObservable<T>): IObservable<T>}
65-
} & {<T>(start: number, count: number): {(source: IObservable<T>): IObservable<T>}} & {
63+
}) as {<T>(start: number, count: number, source: IObservable<T>): IObservable<T>} & {
64+
<T>(start: number): {(count: number, source: IObservable<T>): IObservable<T>}
65+
} & {<T>(start: number, count: number): {(source: IObservable<T>): IObservable<T>}} & {
6666
<T>(start: number): {(count: number): {(source: IObservable<T>): IObservable<T>}}
6767
}

‎src/operators/Switch.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,6 @@ export function switchLatest<T>(source: IObservable<IObservable<T>>): IObservabl
6565
}
6666
export const switchMap = curry(<T, K>(fn: (t: K) => IObservable<T>, source: IObservable<K>) => {
6767
return switchLatest(map(fn, source))
68-
}) as Function & {<T, K>(mapper: (t: K) => IObservable<T>, source: IObservable<K>): IObservable<T>} & {
69-
<T, K>(mapper: (t: K) => IObservable<T>): {(source: IObservable<K>): IObservable<T>}
70-
}
68+
}) as {<T, K>(mapper: (t: K) => IObservable<T>, source: IObservable<K>): IObservable<T>} & {
69+
<T, K>(mapper: (t: K) => IObservable<T>): {(source: IObservable<K>): IObservable<T>}
70+
}

‎src/sources/FromDOM.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,4 +33,4 @@ class DOMObservable implements TResult {
3333

3434
export const fromDOM = curry(function(element: HTMLElement, name: string) {
3535
return new DOMObservable(name, element)
36-
}) as Function & {(element: HTMLElement, name: string): TResult} & {(element: HTMLElement): {(name: string): TResult}}
36+
}) as {(element: HTMLElement, name: string): TResult} & {(element: HTMLElement): {(name: string): TResult}}

0 commit comments

Comments
 (0)