fix(fetch): missed optimized code segmentation

Author: StephanGerbeth

packages/operators/src/fetch/resolve.test.js

@@ -1,6 +1,22 @@
 import { shallowEqual } from 'fast-equals';
 import { concatMap, distinctUntilChanged, map } from 'rxjs';
 
+export const resolve = (type = 'json') => {
+  return source => source.pipe(concatMap(e => e[String(type)]()));
+};
+
+export const resolveJSON = () => {
+  return resolve('json');
+};
+
+export const resolveText = () => {
+  return resolve('text');
+};
+
+export const resolveBlob = () => {
+  return resolve('blob');
+};
+
 export const distinctUntilResponseChanged = () => {
   return source =>
     source.pipe(

packages/operators/src/fetch/response.js

@@ -2,8 +2,7 @@ import { of } from 'rxjs';
 import { afterEach, test, describe, beforeEach, expect } from 'vitest';
 
 import { log } from '../log';
-import { resolveText } from './resolve';
-import { distinctUntilResponseChanged } from './response';
+import { distinctUntilResponseChanged, resolveJSON, resolveText } from './response';
 
 describe('response', function () {
   beforeEach(function () {
@@ -14,6 +13,28 @@ describe('response', function () {
     //
   });
 
+  test('resolve json', () => {
+    return new Promise(done => {
+      of(new Response(JSON.stringify({ hello: 'world' })))
+        .pipe(resolveJSON(), log(false))
+        .subscribe({
+          next: e => expect(e).includes({ hello: 'world' }),
+          complete: () => done()
+        });
+    });
+  });
+
+  test('resolve text', () => {
+    return new Promise(done => {
+      of(new Response('hello world'))
+        .pipe(resolveText(), log(false))
+        .subscribe({
+          next: e => expect(e).toBe('hello world'),
+          complete: () => done()
+        });
+    });
+  });
+
   test('emit only changed responses', () => {
     const triggerValues = [
       new Response('a'),