style: update linting

benchmarks/src/async.ts

@@ -1,6 +1,6 @@
 import {testIterOps} from './tests/iter-ops';
 import {testRXJS} from './tests/rxjs';
-import {toAsync} from '../../dist';
+import {toAsync} from '../../';
 
 // tslint:disable:no-console
 
@@ -16,8 +16,8 @@ const input: AsyncIterable<number> = {
     [Symbol.asyncIterator](): AsyncIterator<number> {
         const i = data.values();
         return {
-            async next(): Promise<IteratorResult<number>> {
-                return i.next();
+            next(): Promise<IteratorResult<number>> {
+                return Promise.resolve(i.next());
             }
         };
     }

benchmarks/src/tests/iter-ops.ts

@@ -1,4 +1,4 @@
-import {UnknownIterable, filter, map, pipe, toArray} from '../../../dist';
+import {type UnknownIterable, filter, map, pipe, toArray} from '../../../';
 
 export async function testIterOps(input: UnknownIterable<number>) {
     const start = Date.now();

benchmarks/src/tests/rxjs.ts

@@ -1,4 +1,4 @@
-import {UnknownIterable} from '../../../dist';
+import type {UnknownIterable} from '../../../';
 import {filter, firstValueFrom, from, map, toArray} from 'rxjs';
 
 export async function testRXJS(

src/helpers.ts

@@ -8,7 +8,7 @@ import {
     isIndexed,
     isArrayLike
 } from './typeguards';
-import {$A, $S, UnknownIterable} from './types';
+import {$A, $S, type UnknownIterable} from './types';
 import {indexedAsyncIterable} from './utils';
 
 /**

src/index.ts

@@ -1,4 +1,4 @@
-export {
+export type {
     AsyncIterableExt,
     IErrorContext,
     IterableExt,
@@ -18,7 +18,7 @@ export {pipe, pipeSync, pipeAsync} from './pipe';
 export {aggregate} from './ops/aggregate';
 export {catchError} from './ops/catch-error';
 export {concat} from './ops/concat';
-export {concurrencyFork, IConcurrencyWork} from './ops/concurrency-fork';
+export {concurrencyFork, type IConcurrencyWork} from './ops/concurrency-fork';
 export {consume} from './ops/consume';
 export {count} from './ops/count';
 export {defaultEmpty} from './ops/default-empty';
@@ -31,15 +31,15 @@ export {filter} from './ops/filter';
 export {first} from './ops/first';
 export {flat} from './ops/flat';
 export {flatMap} from './ops/flat-map';
-export {indexBy, IIndexedValue} from './ops/index-by';
+export {indexBy, type IIndexedValue} from './ops/index-by';
 export {isEmpty} from './ops/is-empty';
 export {last} from './ops/last';
 export {map} from './ops/map';
 export {
     onEnd,
-    IIterationSummary,
-    IDuration,
-    IValueDuration
+    type IIterationSummary,
+    type IDuration,
+    type IValueDuration
 } from './ops/on-end';
 export {page} from './ops/page';
 export {reduce} from './ops/reduce';
@@ -49,7 +49,12 @@ export {skip} from './ops/skip';
 export {skipUntil} from './ops/skip-until';
 export {skipWhile} from './ops/skip-while';
 export {some} from './ops/some';
-export {split, ISplitIndex, ISplitOptions, SplitValueCarry} from './ops/split';
+export {
+    split,
+    type ISplitIndex,
+    type ISplitOptions,
+    SplitValueCarry
+} from './ops/split';
 export {spread} from './ops/spread';
 export {take} from './ops/take';
 export {takeLast} from './ops/take-last';
@@ -58,7 +63,7 @@ export {takeWhile} from './ops/take-while';
 export {tap} from './ops/tap';
 export {throttle} from './ops/async/throttle';
 export {timeout} from './ops/timeout';
-export {timing, IValueTiming} from './ops/timing';
+export {timing, type IValueTiming} from './ops/timing';
 export {toArray} from './ops/to-array';
 export {wait} from './ops/async/wait';
 export {waitRace} from './ops/async/wait-race';

src/ops/aggregate.ts

@@ -1,4 +1,4 @@
-import {$A, $S, Operation} from '../types';
+import {$A, $S, type Operation} from '../types';
 import {createOperation} from '../utils';
 import {isPromiseLike} from '../typeguards';
 

src/ops/async/delay.ts

@@ -1,4 +1,4 @@
-import {$A, Operation, IterationState} from '../../types';
+import {$A, type Operation, type IterationState} from '../../types';
 import {createOperation, throwOnSync} from '../../utils';
 
 /**

src/ops/async/throttle.ts

@@ -1,4 +1,4 @@
-import {$A, IterationState, Operation} from '../../types';
+import {$A, type IterationState, type Operation} from '../../types';
 import {createOperation, throwOnSync} from '../../utils';
 
 /**

src/ops/async/wait-race.ts

@@ -1,4 +1,4 @@
-import {$A, Operation} from '../../types';
+import {$A, type Operation} from '../../types';
 import {isPromiseLike} from '../../typeguards';
 import {createOperation, throwOnSync} from '../../utils';
 
@@ -114,6 +114,7 @@ export function waitRaceAsync<T>(
                             },
                             (err) => {
                                 // handle rejections from calling `i.next()`
+                                // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
                                 resolvers.shift()?.(Promise.reject(err));
                                 finished = true;
                             }

src/ops/async/wait.ts

@@ -1,4 +1,4 @@
-import {$A, Operation} from '../../types';
+import {$A, type Operation} from '../../types';
 import {isPromiseLike} from '../../typeguards';
 import {createOperation, throwOnSync} from '../../utils';
 

src/ops/catch-error.ts

@@ -1,4 +1,10 @@
-import {$A, $S, IErrorContext, IterationState, Operation} from '../types';
+import {
+    $A,
+    $S,
+    type IErrorContext,
+    type IterationState,
+    type Operation
+} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/concat.ts

@@ -1,10 +1,10 @@
 import {
     $A,
     $S,
-    Value,
-    SyncValue,
-    Operation,
-    UnknownIterableOrIterator
+    type Value,
+    type SyncValue,
+    type Operation,
+    type UnknownIterableOrIterator
 } from '../types';
 import {createOperation} from '../utils';
 import {isPromiseLike} from '../typeguards';

src/ops/concurrency-fork.ts

@@ -129,6 +129,7 @@ function concurrencyForkAsync<T, R>(
                             return Promise.resolve({value: undefined, done});
                         }
                         done = true;
+                        // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
                         return Promise.reject(err); // now catchError operator can handle the error
                     }
                 };

src/ops/count.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';
 

src/ops/default-empty.ts

@@ -1,9 +1,9 @@
 import {
-    Value,
-    SyncValue,
-    UnknownIterable,
-    UnknownIterator,
-    Operation,
+    type Value,
+    type SyncValue,
+    type UnknownIterable,
+    type UnknownIterator,
+    type Operation,
     $S,
     $A
 } from '../types';

src/ops/distinct.ts

@@ -1,4 +1,4 @@
-import {$A, $S, Operation} from '../types';
+import {$A, $S, type Operation} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/drain.ts

@@ -1,4 +1,4 @@
-import {$A, $S, Operation} from '../types';
+import {$A, $S, type Operation} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/empty.ts

@@ -1,4 +1,4 @@
-import {$A, $S, Operation} from '../types';
+import {$A, $S, type Operation} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/every.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';
 

src/ops/filter.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';
 

src/ops/first.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';
 

src/ops/flat-map.ts

@@ -1,4 +1,10 @@
-import {$A, $S, IterationState, Operation, UnknownIterable} from '../types';
+import {
+    $A,
+    $S,
+    type IterationState,
+    type Operation,
+    type UnknownIterable
+} from '../types';
 import {createOperation} from '../utils';
 import {isPromiseLike} from '../typeguards';
 

src/ops/flat.ts

@@ -1,4 +1,10 @@
-import {$A, $S, Decrement, Operation, UnknownIterable} from '../types';
+import {
+    $A,
+    $S,
+    type Decrement,
+    type Operation,
+    type UnknownIterable
+} from '../types';
 import {createOperation} from '../utils';
 
 /**
@@ -9,19 +15,19 @@ export type Flatten<T, N extends number> =
     `${N}` extends `-${string}`
         ? T
         : // N = 0
-        N extends 0
-        ? T
-        : // N = 1
-        N extends 1
-        ? T extends UnknownIterable<infer E>
-            ? E
-            : T
-        : // N > 20 or N is unknown
-        Decrement[number] extends Decrement[N]
-        ? unknown
-        : T extends UnknownIterable<infer E>
-        ? Flatten<E, Decrement[N]>
-        : Flatten<T, Decrement[N]>;
+          N extends 0
+          ? T
+          : // N = 1
+            N extends 1
+            ? T extends UnknownIterable<infer E>
+                ? E
+                : T
+            : // N > 20 or N is unknown
+              Decrement[number] extends Decrement[N]
+              ? unknown
+              : T extends UnknownIterable<infer E>
+                ? Flatten<E, Decrement[N]>
+                : Flatten<T, Decrement[N]>;
 
 /**
  * Expands / flattens sub-iterables up to the specified `depth` (default is 1), with support for `skip` logic.

src/ops/index-by.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';
 

src/ops/is-empty.ts

@@ -1,4 +1,4 @@
-import {$A, $S, Operation} from '../types';
+import {$A, $S, type Operation} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/last.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';
 

src/ops/map.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/on-end.ts

@@ -1,4 +1,4 @@
-import {$A, $S, Operation} from '../types';
+import {$A, $S, type Operation} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/page.ts

@@ -1,4 +1,4 @@
-import {$A, $S, Operation} from '../types';
+import {$A, $S, type Operation} from '../types';
 import {createOperation, iterateOnce} from '../utils';
 
 /**

src/ops/reduce.ts

@@ -1,5 +1,5 @@
 import {isPromiseLike} from '../typeguards';
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/repeat.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/retry.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';
 
@@ -153,7 +153,10 @@ function retryAsync<T>(
                         (e) => {
                             if (cb) {
                                 const b = (f: any) =>
-                                    f ? this.next() : Promise.reject(e);
+                                    f
+                                        ? this.next()
+                                        : // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
+                                          Promise.reject(e);
                                 const r = cb(
                                     index++,
                                     attempts++,
@@ -165,6 +168,7 @@ function retryAsync<T>(
                                 leftTries--;
                                 return this.next();
                             }
+                            // eslint-disable-next-line @typescript-eslint/prefer-promise-reject-errors
                             return Promise.reject(e);
                         }
                     );

src/ops/skip-until.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';
 

src/ops/skip-while.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';
 

src/ops/skip.ts

@@ -1,4 +1,4 @@
-import {$A, $S, Operation} from '../types';
+import {$A, $S, type Operation} from '../types';
 import {createOperation} from '../utils';
 
 /**

src/ops/some.ts

@@ -1,4 +1,4 @@
-import {$A, $S, IterationState, Operation} from '../types';
+import {$A, $S, type IterationState, type Operation} from '../types';
 import {isPromiseLike} from '../typeguards';
 import {createOperation} from '../utils';