refactor(core): use RefactorStreamItem type in rxResource (#59887)

cexbrayat · kirjs · commit 3c644688ebce · 2025-06-04T11:45:05.000-04:00
The `ResourceStreamItem` was introduced in #59851 and can be used to simplify the `rxResource` code. PR Close #59887
diff --git 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;
