light-observable - npm Package Compare versions

Comparing version 2.1.0 to 2.1.1

helpers/curry.js

 export const curry = (fn) => {
-    return ((a) => (b) => fn(a, b));
+    return (a) => (b) => fn(a, b);
 };

package.json

 {
   "name": "light-observable",
-  "version": "2.1.0",
+  "version": "2.1.1",
   "description": "Light observable ponyfill",
@@ -30,3 +30,3 @@ "main": "index.js",
   "lint-staged": {
-    "src/**/*.{ts,tsx}": [
+    "./src/**/*.{ts,tsx}": [
       "prettier --write --config .prettierrc",
@@ -33,0 +33,0 @@ "git add"

types/helpers/curry.d.ts

@@ -1,4 +0,1 @@
-import { Unary } from './pipe';
-declare type Curry<F> = F extends ((a: infer A, b: infer B) => infer R) ? Unary<A, Unary<B, R>> : F;
-export declare const curry: <T extends (a: any, b: any) => any>(fn: T) => Curry<T>;
-export {};
+export declare const curry: <A, B, R>(fn: (a: A, b: B) => R) => (a: A) => (b: B) => R;

types/helpers/transform.d.ts

@@ -0,2 +1,3 @@
+import { Observable } from '..';
 import { Observer, Subscribable } from '../core/types.h';
-export declare const transform: <T, R = T>(stream: Subscribable<T>, fn: (observer: Observer<R>, value: T) => void) => import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/Observable").Observable<R>;
+export declare const transform: <T, R = T>(stream: Subscribable<T>, fn: (observer: Observer<R>, value: T) => void) => Observable<R>;

types/operators/catchError.d.ts

@@ -1,1 +0,3 @@
-export declare const catchError: import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<(reason: any) => import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/types.h").Subscribable<{}>, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/types.h").Subscribable<{}>, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/Observable").Observable<{}>>>;
+import { Observable } from '..';
+import { Subscribable } from '../core/types.h';
+export declare const catchError: <T>(fn: (reason: any) => Subscribable<T>) => (stream: Subscribable<T>) => Observable<T>;

types/operators/filter.d.ts

@@ -1,1 +0,3 @@
-export declare const filter: import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<(value: {}) => boolean, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/types.h").Subscribable<{}>, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/Observable").Observable<{}>>>;
+import { Observable } from '..';
+import { Subscribable } from '../core/types.h';
+export declare const filter: <T>(fn: (value: T) => boolean) => (stream: Subscribable<T>) => Observable<T>;

types/operators/forEach.d.ts

@@ -1,1 +0,2 @@
-export declare const forEach: import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<((value: {}) => void) | undefined, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/types.h").Subscribable<{}>, Promise<{}>>>;
+import { Subscribable } from '../core/types.h';
+export declare const forEach: <S>(fn?: (value: S) => void) => (stream: Subscribable<S>) => Promise<S>;

types/operators/map.d.ts

@@ -1,1 +0,3 @@
-export declare const map: import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<(value: {}) => {}, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/types.h").Subscribable<{}>, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/Observable").Observable<{}>>>;
+import { Observable } from '..';
+import { Subscribable } from '../core/types.h';
+export declare const map: <T, R>(fn: (value: T) => R) => (stream: Subscribable<T>) => Observable<R>;

types/operators/skipRepeats.d.ts

@@ -1,1 +0,3 @@
-export declare const skipRepeats: import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<((a: {}, b: {}) => boolean) | undefined, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/types.h").Subscribable<{}>, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/Observable").Observable<{}>>>;
+import { Observable } from '..';
+import { Subscribable } from '../core/types.h';
+export declare const skipRepeats: <T>(equals: (a: T, b: T) => boolean) => (stream: Subscribable<T>) => Observable<T>;

types/operators/tap.d.ts

@@ -1,1 +0,3 @@
-export declare const tap: import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<(value: {}) => any, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/types.h").Subscribable<{}>, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/Observable").Observable<{}>>>;
+import { Observable } from '..';
+import { Subscribable } from '../core/types.h';
+export declare const tap: <T>(fn: (value: T) => any) => (stream: Subscribable<T>) => Observable<T>;

types/operators/throttle.d.ts

@@ -1,1 +0,3 @@
-export declare const throttle: import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<number, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/types.h").Subscribable<{}>, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/Observable").Observable<any>>>;
+import { Observable } from '..';
+import { Subscribable } from '../core/types.h';
+export declare const throttle: <T>(time: number) => (stream: Subscribable<T>) => Observable<T>;

types/operators/timeout.d.ts

@@ -1,1 +0,2 @@
-export declare const timeout: import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<number, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/helpers/pipe").Unary<import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/types.h").Subscribable<{}>, import("../../../../../../Users/d.a.korolev/Projects/light-observable/src/core/Observable").Observable<{}>>>;
+import { Observable, Subscribable } from '..';
+export declare const timeout: <T>(time: number) => (stream: Subscribable<T>) => Observable<T>;

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

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Lines of code

759

increased by0.4%

Number of medium supply chain risk alerts

0

decreased by-100%

Worsened metrics

Total package byte prevSize

48525

decreased by-4.82%

No dependency changes