wonka - npm Package Compare versions

Comparing version 4.0.0-rc.4 to 4.0.0

dist/types/src/helpers/pipe.d.ts

 import { sourceT as Source } from '../wonka_types.gen';
-declare function pipe<T, A>(source: Source<T>, op1: (source: Source<T>) => Source<A>): Source<A>;
-declare function pipe<T, A, B>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>): Source<B>;
-declare function pipe<T, A, B, C>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>): Source<C>;
-declare function pipe<T, A, B, C, D>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>): Source<D>;
-declare function pipe<T, A, B, C, D, E>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>, op5: (source: Source<D>) => Source<E>): Source<E>;
-declare function pipe<T, A, B, C, D, E, F>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>, op5: (source: Source<D>) => Source<E>, op6: (source: Source<E>) => Source<F>): Source<F>;
-declare function pipe<T, A, B, C, D, E, F, G>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>, op5: (source: Source<D>) => Source<E>, op6: (source: Source<E>) => Source<F>, op7: (source: Source<F>) => Source<G>): Source<G>;
-declare function pipe<T, A, B, C, D, E, F, G, H>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>, op5: (source: Source<D>) => Source<E>, op6: (source: Source<E>) => Source<F>, op7: (source: Source<F>) => Source<G>, op8: (source: Source<G>) => Source<H>): Source<H>;
-declare function pipe<T, R>(source: Source<T>, consumer: (source: Source<T>) => R): R;
-declare function pipe<T, A, R>(source: Source<T>, op1: (source: Source<T>) => Source<A>, consumer: (source: Source<A>) => R): R;
-declare function pipe<T, A, B, R>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, consumer: (source: Source<B>) => R): R;
-declare function pipe<T, A, B, C, R>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, consumer: (source: Source<C>) => R): R;
-declare function pipe<T, A, B, C, D, R>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>, consumer: (source: Source<D>) => R): R;
-declare function pipe<T, A, B, C, D, E, R>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>, op5: (source: Source<D>) => Source<E>, consumer: (source: Source<E>) => R): R;
-declare function pipe<T, A, B, C, D, E, F, R>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>, op5: (source: Source<D>) => Source<E>, op6: (source: Source<E>) => Source<F>, consumer: (source: Source<F>) => R): R;
-declare function pipe<T, A, B, C, D, E, F, G, R>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>, op5: (source: Source<D>) => Source<E>, op6: (source: Source<E>) => Source<F>, op7: (source: Source<F>) => Source<G>, consumer: (source: Source<G>) => R): R;
-declare function pipe<T, A, B, C, D, E, F, G, H, R>(source: Source<T>, op1: (source: Source<T>) => Source<A>, op2: (source: Source<A>) => Source<B>, op3: (source: Source<B>) => Source<C>, op4: (source: Source<C>) => Source<D>, op5: (source: Source<D>) => Source<E>, op6: (source: Source<E>) => Source<F>, op7: (source: Source<F>) => Source<G>, op8: (source: Source<G>) => Source<H>, consumer: (source: Source<H>) => R): R;
+interface UnaryFn<T, R> {
+    (source: T): R;
+}
+declare function pipe<T, A>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>): Source<A>;
+declare function pipe<T, A, B>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>): Source<B>;
+declare function pipe<T, A, B, C>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>): Source<C>;
+declare function pipe<T, A, B, C, D>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>): Source<D>;
+declare function pipe<T, A, B, C, D, E>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>, op5: UnaryFn<Source<D>, Source<E>>): Source<E>;
+declare function pipe<T, A, B, C, D, E, F>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>, op5: UnaryFn<Source<D>, Source<E>>, op6: UnaryFn<Source<E>, Source<F>>): Source<F>;
+declare function pipe<T, A, B, C, D, E, F, G>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>, op5: UnaryFn<Source<D>, Source<E>>, op6: UnaryFn<Source<E>, Source<F>>, op7: UnaryFn<Source<F>, Source<G>>): Source<G>;
+declare function pipe<T, A, B, C, D, E, F, G, H>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>, op5: UnaryFn<Source<D>, Source<E>>, op6: UnaryFn<Source<E>, Source<F>>, op7: UnaryFn<Source<F>, Source<G>>, op8: UnaryFn<Source<G>, Source<H>>): Source<H>;
+declare function pipe<T, R>(source: Source<T>, consumer: UnaryFn<Source<T>, R>): R;
+declare function pipe<T, A, R>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, consumer: UnaryFn<Source<A>, R>): R;
+declare function pipe<T, A, B, R>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, consumer: UnaryFn<Source<B>, R>): R;
+declare function pipe<T, A, B, C, R>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, consumer: UnaryFn<Source<C>, R>): R;
+declare function pipe<T, A, B, C, D, R>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>, consumer: UnaryFn<Source<D>, R>): R;
+declare function pipe<T, A, B, C, D, E, R>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>, op5: UnaryFn<Source<D>, Source<E>>, consumer: UnaryFn<Source<E>, R>): R;
+declare function pipe<T, A, B, C, D, E, F, R>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>, op5: UnaryFn<Source<D>, Source<E>>, op6: UnaryFn<Source<E>, Source<F>>, consumer: UnaryFn<Source<F>, R>): R;
+declare function pipe<T, A, B, C, D, E, F, G, R>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>, op5: UnaryFn<Source<D>, Source<E>>, op6: UnaryFn<Source<E>, Source<F>>, op7: UnaryFn<Source<F>, Source<G>>, consumer: UnaryFn<Source<G>, R>): R;
+declare function pipe<T, A, B, C, D, E, F, G, H, R>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>, op2: UnaryFn<Source<A>, Source<B>>, op3: UnaryFn<Source<B>, Source<C>>, op4: UnaryFn<Source<C>, Source<D>>, op5: UnaryFn<Source<D>, Source<E>>, op6: UnaryFn<Source<E>, Source<F>>, op7: UnaryFn<Source<F>, Source<G>>, op8: UnaryFn<Source<G>, Source<H>>, consumer: UnaryFn<Source<H>, R>): R;
 export { pipe };

package.json

 {
   "name": "wonka",
   "description": "A fast push & pull stream library for Reason/OCaml, Flow, and TypeScript",
-  "version": "4.0.0-rc.4",
+  "version": "4.0.0",
   "author": "Phil Pluckthun <[e-mail]>",
@@ -6,0 +6,0 @@ "source": "./src/wonka.ts",

src/helpers/pipe.ts

 import { sourceT as Source } from '../wonka_types.gen';
 
+interface UnaryFn<T, R> {
+  (source: T): R;
+}
+
 /* pipe definitions for source + operators composition */
 
-function pipe<T, A>(source: Source<T>, op1: (source: Source<T>) => Source<A>): Source<A>;
+function pipe<T, A>(source: Source<T>, op1: UnaryFn<Source<T>, Source<A>>): Source<A>;
 
 function pipe<T, A, B>(
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>
 ): Source<B>;
@@ -15,5 +19,5 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>
 ): Source<C>;
@@ -23,6 +27,6 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>
 ): Source<D>;
@@ -32,7 +36,7 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>,
-  op5: (source: Source<D>) => Source<E>
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>,
+  op5: UnaryFn<Source<D>, Source<E>>
 ): Source<E>;
@@ -42,8 +46,8 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>,
-  op5: (source: Source<D>) => Source<E>,
-  op6: (source: Source<E>) => Source<F>
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>,
+  op5: UnaryFn<Source<D>, Source<E>>,
+  op6: UnaryFn<Source<E>, Source<F>>
 ): Source<F>;
@@ -53,9 +57,9 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>,
-  op5: (source: Source<D>) => Source<E>,
-  op6: (source: Source<E>) => Source<F>,
-  op7: (source: Source<F>) => Source<G>
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>,
+  op5: UnaryFn<Source<D>, Source<E>>,
+  op6: UnaryFn<Source<E>, Source<F>>,
+  op7: UnaryFn<Source<F>, Source<G>>
 ): Source<G>;
@@ -65,10 +69,10 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>,
-  op5: (source: Source<D>) => Source<E>,
-  op6: (source: Source<E>) => Source<F>,
-  op7: (source: Source<F>) => Source<G>,
-  op8: (source: Source<G>) => Source<H>
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>,
+  op5: UnaryFn<Source<D>, Source<E>>,
+  op6: UnaryFn<Source<E>, Source<F>>,
+  op7: UnaryFn<Source<F>, Source<G>>,
+  op8: UnaryFn<Source<G>, Source<H>>
 ): Source<H>;
@@ -78,8 +82,8 @@
 
-function pipe<T, R>(source: Source<T>, consumer: (source: Source<T>) => R): R;
+function pipe<T, R>(source: Source<T>, consumer: UnaryFn<Source<T>, R>): R;
 
 function pipe<T, A, R>(
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  consumer: (source: Source<A>) => R
+  op1: UnaryFn<Source<T>, Source<A>>,
+  consumer: UnaryFn<Source<A>, R>
 ): R;
@@ -89,5 +93,5 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  consumer: (source: Source<B>) => R
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  consumer: UnaryFn<Source<B>, R>
 ): R;
@@ -97,6 +101,6 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  consumer: (source: Source<C>) => R
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  consumer: UnaryFn<Source<C>, R>
 ): R;
@@ -106,7 +110,7 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>,
-  consumer: (source: Source<D>) => R
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>,
+  consumer: UnaryFn<Source<D>, R>
 ): R;
@@ -116,8 +120,8 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>,
-  op5: (source: Source<D>) => Source<E>,
-  consumer: (source: Source<E>) => R
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>,
+  op5: UnaryFn<Source<D>, Source<E>>,
+  consumer: UnaryFn<Source<E>, R>
 ): R;
@@ -127,9 +131,9 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>,
-  op5: (source: Source<D>) => Source<E>,
-  op6: (source: Source<E>) => Source<F>,
-  consumer: (source: Source<F>) => R
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>,
+  op5: UnaryFn<Source<D>, Source<E>>,
+  op6: UnaryFn<Source<E>, Source<F>>,
+  consumer: UnaryFn<Source<F>, R>
 ): R;
@@ -139,10 +143,10 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>,
-  op5: (source: Source<D>) => Source<E>,
-  op6: (source: Source<E>) => Source<F>,
-  op7: (source: Source<F>) => Source<G>,
-  consumer: (source: Source<G>) => R
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>,
+  op5: UnaryFn<Source<D>, Source<E>>,
+  op6: UnaryFn<Source<E>, Source<F>>,
+  op7: UnaryFn<Source<F>, Source<G>>,
+  consumer: UnaryFn<Source<G>, R>
 ): R;
@@ -152,11 +156,11 @@
   source: Source<T>,
-  op1: (source: Source<T>) => Source<A>,
-  op2: (source: Source<A>) => Source<B>,
-  op3: (source: Source<B>) => Source<C>,
-  op4: (source: Source<C>) => Source<D>,
-  op5: (source: Source<D>) => Source<E>,
-  op6: (source: Source<E>) => Source<F>,
-  op7: (source: Source<F>) => Source<G>,
-  op8: (source: Source<G>) => Source<H>,
-  consumer: (source: Source<H>) => R
+  op1: UnaryFn<Source<T>, Source<A>>,
+  op2: UnaryFn<Source<A>, Source<B>>,
+  op3: UnaryFn<Source<B>, Source<C>>,
+  op4: UnaryFn<Source<C>, Source<D>>,
+  op5: UnaryFn<Source<D>, Source<E>>,
+  op6: UnaryFn<Source<E>, Source<F>>,
+  op7: UnaryFn<Source<F>, Source<G>>,
+  op8: UnaryFn<Source<G>, Source<H>>,
+  consumer: UnaryFn<Source<H>, R>
 ): R;
@@ -163,0 +167,0 @@

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

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

370985

increased by0.79%

Number of package files

106

increased by0.95%

Lines of code

7801

increased by0.08%

Number of low quality alerts

0

decreased by-100%

No dependency changes