light-observable - npm Package Compare versions

Comparing version 2.2.0 to 2.3.0

core/Observable.d.ts

 import { Unary } from '../helpers/pipe';
 import { ObservableSubscription } from './ObservableSubscription';
-import { PartialObserver, Subscribable, Subscriber } from './types.h';
+import { FromInput, PartialObserver, Subscribable, Subscriber } from './types.h';
 export declare class Observable<T> implements Subscribable<T> {
@@ -11,6 +11,3 @@ static of(): Observable<any>;
     static of<A, B, C, D, E>(a: A, b: B, c: C, d: D, e: E): Observable<A | B | C | D | E>;
-    static from<A>(ish: Subscribable<A>): Observable<A>;
-    static from<A>(ish: Iterable<A>): Observable<A>;
-    static from<A>(ish: Promise<A>): Observable<A>;
-    static from<A>(ish: A[]): Observable<A>;
+    static from<A>(ish: FromInput<A>): Observable<A>;
     private _source;
@@ -17,0 +14,0 @@ constructor(source: Subscriber<T>);

core/types.h.d.ts

@@ -41,2 +41,3 @@ export declare type Subscription = {
 };
+export declare type FromInput<T> = Subscribable<T> | Iterable<T> | T[];
 export declare const enum SignalType {
@@ -43,0 +44,0 @@ next = 0,

observable/index.d.ts

@@ -10,7 +10,10 @@ export { auditTime } from './auditTime';
 export { map } from './map';
+export { mapTo } from './mapTo';
 export { merge } from './merge';
 export { of } from './of';
 export { skipRepeats } from './skipRepeats';
+export { switchMap } from './switchMap';
+export { switchMapTo } from './switchMapTo';
 export { tap } from './tap';
 export { throttleTime } from './throttleTime';
 export { timeout } from './timeout';

observable/index.js

@@ -10,7 +10,10 @@ export { auditTime } from './auditTime';
 export { map } from './map';
+export { mapTo } from './mapTo';
 export { merge } from './merge';
 export { of } from './of';
 export { skipRepeats } from './skipRepeats';
+export { switchMap } from './switchMap';
+export { switchMapTo } from './switchMapTo';
 export { tap } from './tap';
 export { throttleTime } from './throttleTime';
 export { timeout } from './timeout';

operators/auditTime.js

@@ -1,3 +0,2 @@
-import { curry } from '../helpers/curry';
 import { auditTime as auditTimeObservable } from '../observable/auditTime';
-export const auditTime = curry(auditTimeObservable);
+export const auditTime = (time) => (stream) => auditTimeObservable(time, stream);

operators/catchError.js

@@ -1,3 +0,2 @@
-import { curry } from '../helpers/curry';
 import { catchError as catchErrorObservable } from '../observable/catchError';
-export const catchError = curry(catchErrorObservable);
+export const catchError = (fn) => (stream) => catchErrorObservable(fn, stream);

operators/filter.js

@@ -1,3 +0,2 @@
-import { curry } from '../helpers/curry';
 import { filter as filterObservable } from '../observable/filter';
-export const filter = curry(filterObservable);
+export const filter = (fn) => (stream) => filterObservable(fn, stream);

operators/forEach.d.ts

 import { Subscribable } from '../core/types.h';
-export declare const forEach: <S>(fn?: (value: S) => void) => (stream: Subscribable<S>) => Promise<S>;
+export declare const forEach: <S>(fn?: ((value: S) => void) | undefined) => (stream: Subscribable<S>) => Promise<void>;

operators/forEach.js

@@ -1,3 +0,2 @@
-import { curry } from '../helpers/curry';
 import { forEach as forEachObservable } from '../observable/forEach';
-export const forEach = curry(forEachObservable);
+export const forEach = (fn) => (stream) => forEachObservable(fn, stream);

operators/index.d.ts

@@ -6,6 +6,8 @@ export { auditTime } from './auditTime';
 export { map } from './map';
+export { mapTo } from './mapTo';
 export { merge } from './merge';
 export { skipRepeats } from './skipRepeats';
+export { switchMapTo } from './switchMapTo';
 export { tap } from './tap';
 export { throttleTime } from './throttleTime';
 export { timeout } from './timeout';

operators/index.js

@@ -6,6 +6,8 @@ export { auditTime } from './auditTime';
 export { map } from './map';
+export { mapTo } from './mapTo';
 export { merge } from './merge';
 export { skipRepeats } from './skipRepeats';
+export { switchMapTo } from './switchMapTo';
 export { tap } from './tap';
 export { throttleTime } from './throttleTime';
 export { timeout } from './timeout';

operators/map.js

@@ -1,3 +0,2 @@
-import { curry } from '../helpers/curry';
 import { map as mapObservable } from '../observable/map';
-export const map = curry(mapObservable);
+export const map = (fn) => (stream) => mapObservable(fn, stream);

operators/skipRepeats.d.ts

 import { Observable } from '../core/Observable';
 import { Subscribable } from '../core/types.h';
-export declare const skipRepeats: <T>(equals: (a: T, b: T) => boolean) => (stream: Subscribable<T>) => Observable<T>;
+export declare const skipRepeats: <T>(equals?: ((a: T, b: T) => boolean) | undefined) => (stream: Subscribable<T>) => Observable<T>;

operators/skipRepeats.js

@@ -1,3 +0,2 @@
-import { curry } from '../helpers/curry';
 import { skipRepeats as skipRepeatsObservable } from '../observable/skipRepeats';
-export const skipRepeats = curry(skipRepeatsObservable);
+export const skipRepeats = (equals) => (stream) => skipRepeatsObservable(equals, stream);

operators/tap.js

@@ -1,3 +0,2 @@
-import { curry } from '../helpers/curry';
 import { tap as tapObservable } from '../observable/tap';
-export const tap = curry(tapObservable);
+export const tap = (fn) => (stream) => tapObservable(fn, stream);

operators/throttleTime.js

@@ -1,3 +0,2 @@
-import { curry } from '../helpers/curry';
 import { throttleTime as throttleObservable } from '../observable/throttleTime';
-export const throttleTime = curry(throttleObservable);
+export const throttleTime = (time) => (stream) => throttleObservable(time, stream);

operators/timeout.js

@@ -1,3 +0,2 @@
-import { curry } from '../helpers/curry';
 import { timeout as timeoutObservable } from '../observable/timeout';
-export const timeout = curry(timeoutObservable);
+export const timeout = (time) => (stream) => timeoutObservable(time, stream);

package.json

 {
   "name": "light-observable",
-  "version": "2.2.0",
+  "version": "2.3.0",
   "description": "Light observable ponyfill",
@@ -5,0 +5,0 @@ "main": "index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

52842

increased by8.53%

Number of package files

95

increased by11.76%

Lines of code

859

increased by11.85%

No dependency changes