expose BehaviorObservable

src/BehaviorObservable.ts

@@ -0,0 +1,5 @@
+import { Observable } from "rxjs"
+
+export interface BehaviorObservable<T> extends Observable<T> {
+  getValue: () => T
+}

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"

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<T> extends Observable<T> {
-  getValue: () => T
-}
-
-const EMPTY_VALUE: any = {}
+export const EMPTY_VALUE: any = {}
 export const distinctShareReplay = <T>(
   compareFn: (a: T, b: T) => boolean = Object.is,
   teardown = defaultTeardown,

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" ||