introduce a named type to represent the untyped teardown function to …

…be exported with the public API

src/index.ts

@@ -1,20 +1,22 @@
 import {
   iterified,
-  type Iterified,
+  type ExecutorFunction,
   type IterifiedIterable,
   type IterifiedIterator,
+  type ExecutorFn,
+  type Iterified,
 } from './iterified';
 import { iterifiedUnwrapped, type IterifiedUnwrapped } from './iterifiedUnwrapped';
-import { type ExecutorFn } from './utils/types/ExecutorFn';
 
 export {
   iterified,
   iterifiedUnwrapped,
-  type ExecutorFn,
-  type Iterified,
+  type ExecutorFunction,
   type IterifiedIterable,
   type IterifiedUnwrapped,
   type IterifiedIterator,
+  type ExecutorFn,
+  type Iterified,
 };
 
 // TODO: Should implement such that when an instance is ended (or all has all its active iterators closed), it can always be reinitialized by just consuming it again, similarly with RxJS observables?

src/iterified.ts

@@ -1,5 +1,5 @@
+import { type MaybePromise } from './utils/types/MaybePromise';
 import { MulticastChannel, createMulticastChannel } from './utils/createMulticastChannel';
-import { type ExecutorFn } from './utils/types/ExecutorFn';
 
 export {
   iterified,
@@ -97,6 +97,10 @@ function iterified<TNext>(executorFn: ExecutorFn<TNext>): IterifiedIterable<TNex
   }
 }
 
+type IterifiedIterable<TNextValue, TDoneValue = undefined | void> = {
+  [Symbol.asyncIterator](): IterifiedIterator<TNextValue, TDoneValue>;
+};
+
 /**
  * @deprecated This type is deprecated - use {@link IterifiedIterable} instead.
  * @see {@link IterifiedIterable}
@@ -106,11 +110,13 @@ type Iterified<TNextValue, TDoneValue = undefined | void> = IterifiedIterable<
   TDoneValue
 >;
 
-type IterifiedIterable<TNextValue, TDoneValue = undefined | void> = {
-  [Symbol.asyncIterator](): IterifiedIterator<TNextValue, TDoneValue>;
-};
-
 type IterifiedIterator<TNextValue, TDoneValue = undefined | void> = {
   next(): Promise<IteratorResult<TNextValue, TDoneValue>>;
   return(): Promise<IteratorReturnResult<TDoneValue>>;
 };
+
+type ExecutorFn<TNext> = (
+  nextCb: (nextValue: TNext) => void,
+  doneCb: () => void,
+  errorCb: (error: unknown) => void
+) => MaybePromise<void | (() => MaybePromise<void>)>;