fix(angular-query): ensure initial mutation pending state is emitted

Author: ThiloAschebrock

packages/angular-query-experimental/src/__tests__/inject-mutation.test.ts

@@ -62,8 +62,6 @@ describe('injectMutation', () => {
       }))
     })
 
-    TestBed.flushEffects()
-
     mutation.mutate(result)
     vi.advanceTimersByTime(1)
 

packages/angular-query-experimental/src/inject-mutation.ts

@@ -83,14 +83,6 @@ export function injectMutation<
     }
   })
 
-  /**
-   * Computed signal that gets result from mutation cache based on passed options
-   */
-  const resultFromInitialOptionsSignal = computed(() => {
-    const observer = observerSignal()
-    return observer.getCurrentResult()
-  })
-
   /**
    * Signal that contains result set by subscriber
    */
@@ -101,44 +93,44 @@ export function injectMutation<
     TContext
   > | null>(null)
 
-  effect(
-    () => {
-      const observer = observerSignal()
-      const observerOptions = optionsSignal()
+  /**
+   * Computed signal that gets result from mutation cache based on passed options
+   */
+  const resultFromInitialOptionsSignal = computed(() => {
+    const observer = observerSignal()
 
-      untracked(() => {
-        observer.setOptions(observerOptions)
-      })
-    },
-    {
-      injector,
-    },
-  )
+    untracked(() => {
+      const unsubscribe = ngZone.runOutsideAngular(() =>
+        // observer.trackResult is not used as this optimization is not needed for Angular
+        observer.subscribe(
+          notifyManager.batchCalls((state) => {
+            ngZone.run(() => {
+              if (
+                state.isError &&
+                shouldThrowError(observer.options.throwOnError, [state.error])
+              ) {
+                ngZone.onError.emit(state.error)
+                throw state.error
+              }
+
+              resultFromSubscriberSignal.set(state)
+            })
+          }),
+        ),
+      )
+      destroyRef.onDestroy(unsubscribe)
+    })
+
+    return observer.getCurrentResult()
+  })
 
   effect(
     () => {
-      // observer.trackResult is not used as this optimization is not needed for Angular
       const observer = observerSignal()
+      const observerOptions = optionsSignal()
 
       untracked(() => {
-        const unsubscribe = ngZone.runOutsideAngular(() =>
-          observer.subscribe(
-            notifyManager.batchCalls((state) => {
-              ngZone.run(() => {
-                if (
-                  state.isError &&
-                  shouldThrowError(observer.options.throwOnError, [state.error])
-                ) {
-                  ngZone.onError.emit(state.error)
-                  throw state.error
-                }
-
-                resultFromSubscriberSignal.set(state)
-              })
-            }),
-          ),
-        )
-        destroyRef.onDestroy(unsubscribe)
+        observer.setOptions(observerOptions)
       })
     },
     {