test(bind): supports observables of functions

Co-authored-by: Josep M Sobrepere <josepot@gmail.com>

Author: voliva

packages/core/src/bind/connectFactoryObservable.test.tsx

@@ -1,23 +1,29 @@
 import {
-  from,
-  of,
-  defer,
-  concat,
+  act as componentAct,
+  fireEvent,
+  render,
+  screen,
+} from "@testing-library/react"
+import { act as actHook, renderHook } from "@testing-library/react-hooks"
+import React, { FC, Suspense, useState } from "react"
+import {
   BehaviorSubject,
-  throwError,
+  concat,
+  defer,
+  from,
   Observable,
+  of,
   Subject,
+  throwError,
 } from "rxjs"
-import { renderHook, act as actHook } from "@testing-library/react-hooks"
-import { switchMap, delay, take, catchError, map } from "rxjs/operators"
-import { FC, Suspense, useState } from "react"
-import React from "react"
 import {
-  act as componentAct,
-  fireEvent,
-  screen,
-  render,
-} from "@testing-library/react"
+  catchError,
+  delay,
+  map,
+  startWith,
+  switchMap,
+  take,
+} from "rxjs/operators"
 import { bind } from "../"
 import { TestErrorBoundary } from "../test-helpers/TestErrorBoundary"
 
@@ -427,6 +433,27 @@ describe("connectFactoryObservable", () => {
       unmount()
     })
 
+    it("supports streams that emit functions", () => {
+      const values$ = new Subject<number>()
+
+      const [useFunction, function$] = bind(() =>
+        values$.pipe(
+          startWith(0),
+          map((value) => () => value),
+        ),
+      )
+      const subscription = function$().subscribe()
+
+      const { result } = renderHook(() => useFunction())
+
+      expect(result.current()).toBe(0)
+
+      values$.next(1)
+      expect(result.current()).toBe(1)
+
+      subscription.unsubscribe()
+    })
+
     it("if the observable hasn't emitted and a defaultValue is provided, it does not start suspense", () => {
       const number$ = new Subject<number>()
       const [useNumber] = bind(

packages/core/src/bind/connectObservable.test.tsx

@@ -493,6 +493,27 @@ describe("connectObservable", () => {
     expect(errorCallback).not.toHaveBeenCalled()
   })
 
+  it("supports streams that emit functions", () => {
+    const values$ = new Subject<number>()
+
+    const [useFunction, function$] = bind(
+      values$.pipe(
+        startWith(0),
+        map((value) => () => value),
+      ),
+    )
+    const subscription = function$.subscribe()
+
+    const { result } = renderHook(() => useFunction())
+
+    expect(result.current()).toBe(0)
+
+    values$.next(1)
+    expect(result.current()).toBe(1)
+
+    subscription.unsubscribe()
+  })
+
   it("should not trigger suspense when the stream emits synchronously", () => {
     const [useValue] = bind(NEVER.pipe(startWith("Hello")))