From c6f791a9f652d30481da230be8ce129113d8ef13 Mon Sep 17 00:00:00 2001
From: cexbrayat <cedric@ninja-squad.com>
Date: Fri, 7 Feb 2025 16:57:22 +0100
Subject: [PATCH] refactor(core): use RefactorStreamItem type in rxResource

The `ResourceStreamItem` was introduced in #59851 and can be used to simplify the `rxResource` code.
---
 packages/core/rxjs-interop/src/rx_resource.ts | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

diff --git a/packages/core/rxjs-interop/src/rx_resource.ts b/packages/core/rxjs-interop/src/rx_resource.ts
index 3039c680a4e0..6388b3bc354f 100644
--- a/packages/core/rxjs-interop/src/rx_resource.ts
+++ b/packages/core/rxjs-interop/src/rx_resource.ts
@@ -16,6 +16,7 @@ import {
   BaseResourceOptions,
   ɵRuntimeError,
   ɵRuntimeErrorCode,
+  ResourceStreamItem,
 } from '../../src/core';
 import {Observable, Subscription} from 'rxjs';
 import {encapsulateResourceError} from '../../src/resource/resource';
@@ -62,11 +63,11 @@ export function rxResource<T, R>(opts: RxResourceOptions<T, R>): ResourceRef<T |
       params.abortSignal.addEventListener('abort', onAbort);
 
       // Start off stream as undefined.
-      const stream = signal<{value: T} | {error: Error}>({value: undefined as T});
-      let resolve: ((value: Signal<{value: T} | {error: Error}>) => void) | undefined;
-      const promise = new Promise<Signal<{value: T} | {error: Error}>>((r) => (resolve = r));
+      const stream = signal<ResourceStreamItem<T>>({value: undefined as T});
+      let resolve: ((value: Signal<ResourceStreamItem<T>>) => void) | undefined;
+      const promise = new Promise<Signal<ResourceStreamItem<T>>>((r) => (resolve = r));
 
-      function send(value: {value: T} | {error: Error}): void {
+      function send(value: ResourceStreamItem<T>): void {
         stream.set(value);
         resolve?.(stream);
         resolve = undefined;