Cleanup start

Author: danielwerthen

example/index.tsx

@@ -1,7 +1,7 @@
 import 'react-app-polyfill/ie11';
 import * as React from 'react';
 import * as ReactDOM from 'react-dom';
-import { createSharedFetch, syncState, useAsync } from '../.';
+import { createSharedFetch, syncState, useAsync } from '../src/index';
 import { map } from 'rxjs/operators';
 
 interface TodoInterface {

src/exhaustMapWithTrailing.ts

@@ -0,0 +1,36 @@
+import {
+  from,
+  Observable,
+  ObservableInput,
+  OperatorFunction,
+  Subject,
+} from 'rxjs';
+import { exhaustMap, finalize, throttle } from 'rxjs/operators';
+
+/**
+ * Credit to: https://github.com/ReactiveX/rxjs/issues/5004
+ * @param project
+ */
+export function exhaustMapWithTrailing<T, R>(
+  project: (value: T, index: number) => ObservableInput<R>
+): OperatorFunction<T, R> {
+  return (source): Observable<R> => {
+    const release = new Subject();
+
+    return source.pipe(
+      throttle(() => release, {
+        leading: true,
+        trailing: true,
+      }),
+      // TODO: Upgrade to TypeScript 3.6.3 when available and remove the cast
+      // https://github.com/microsoft/TypeScript/issues/33131
+      exhaustMap((value, index) =>
+        from(project(value, index)).pipe(
+          finalize(() => {
+            release.next();
+          })
+        )
+      ) as OperatorFunction<T, R>
+    );
+  };
+}

src/index.tsx

@@ -1,7 +1,6 @@
 import {
   catchError,
   concatMap,
-  exhaustMap,
   filter,
   finalize,
   map,
@@ -12,48 +11,21 @@ import {
   switchMap,
   take,
   tap,
-  throttle,
 } from 'rxjs/operators';
 import {
   BehaviorSubject,
   combineLatest,
   ConnectableObservable,
   from,
   Observable,
-  ObservableInput,
   of,
   OperatorFunction,
   Subject,
   Subscription,
 } from 'rxjs';
 import { fromFetch as defaultFromFetch } from 'rxjs/fetch';
 import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
-
-/**
- * Credit to: https://github.com/ReactiveX/rxjs/issues/5004
- * @param project
- */
-function exhaustMapWithTrailing<T, R>(
-  project: (value: T, index: number) => ObservableInput<R>
-): OperatorFunction<T, R> {
-  return (source): Observable<R> => {
-    const release = new Subject();
-
-    return source.pipe(
-      throttle(() => release, {
-        leading: true,
-        trailing: true,
-      }),
-      exhaustMap((value, index) =>
-        from(project(value, index)).pipe(
-          finalize(() => {
-            release.next();
-          })
-        )
-      )
-    );
-  };
-}
+import { exhaustMapWithTrailing } from './exhaustMapWithTrailing';
 
 export type AsyncResult<T, ERR> = {
   pending: boolean;

src/types.ts

@@ -0,0 +1,11 @@
+import { Observable } from 'rxjs';
+
+export type AsyncResult<T, ERR> = {
+  pending: boolean;
+  result?: T;
+  error?: ERR;
+};
+
+export type ObserveValue = <T>(input: Observable<T>) => Promise<T>;
+
+export type AsyncFactory<T> = (observe: ObserveValue) => Promise<T>;