diff --git a/src/BehaviorObservable.ts b/src/BehaviorObservable.ts new file mode 100644 index 0000000..acfd372 --- /dev/null +++ b/src/BehaviorObservable.ts @@ -0,0 +1,5 @@ +import { Observable } from "rxjs" + +export interface BehaviorObservable extends Observable { + getValue: () => T +} diff --git a/src/index.tsx b/src/index.tsx index e3de98c..9406041 100644 --- a/src/index.tsx +++ b/src/index.tsx @@ -3,6 +3,7 @@ import { unstable_batchedUpdates as batch } from "./utils/react-batched-updates" setBatch(batch as any) export const SUSPENSE = Symbol("SUSPENSE") +export { BehaviorObservable } from "./BehaviorObservable" export { connectObservable } from "./connectObservable" export { connectFactoryObservable } from "./connectFactoryObservable" export { distinctShareReplay } from "./operators/distinct-share-replay" diff --git a/src/operators/distinct-share-replay.ts b/src/operators/distinct-share-replay.ts index afbb128..4c77bea 100644 --- a/src/operators/distinct-share-replay.ts +++ b/src/operators/distinct-share-replay.ts @@ -1,14 +1,10 @@ import { Observable, Subscription, Subject } from "rxjs" -import { SUSPENSE } from "../" +import { SUSPENSE, BehaviorObservable } from "../" import { getBatch } from "../utils/batch" function defaultTeardown() {} -export interface BehaviorObservable extends Observable { - getValue: () => T -} - -const EMPTY_VALUE: any = {} +export const EMPTY_VALUE: any = {} export const distinctShareReplay = ( compareFn: (a: T, b: T) => boolean = Object.is, teardown = defaultTeardown, diff --git a/src/operators/react-enhancer.ts b/src/operators/react-enhancer.ts index 7adc235..766b8e3 100644 --- a/src/operators/react-enhancer.ts +++ b/src/operators/react-enhancer.ts @@ -1,7 +1,6 @@ import { Observable, of, Subscription, Subject, race } from "rxjs" import { delay, takeUntil, take, filter, tap } from "rxjs/operators" -import { BehaviorObservable } from "./distinct-share-replay" -import { SUSPENSE } from "../" +import { BehaviorObservable, SUSPENSE } from "../" const IS_SSR = typeof window === "undefined" ||