diff --git a/package-lock.json b/package-lock.json index abf4cc2..08078d1 100644 --- a/package-lock.json +++ b/package-lock.json @@ -12535,7 +12535,7 @@ }, "packages/observables": { "name": "@rxjs-collection/observables", - "version": "1.0.5-beta.1", + "version": "1.0.5", "license": "MIT", "dependencies": { "@rxjs-collection/operators": "*", @@ -12544,7 +12544,7 @@ }, "packages/operators": { "name": "@rxjs-collection/operators", - "version": "1.0.6-beta.3", + "version": "1.0.6", "license": "MIT", "dependencies": { "@rxjs-collection/observables": "*", diff --git a/packages/observables/CHANGELOG.md b/packages/observables/CHANGELOG.md index 56d83a3..70dadd3 100644 --- a/packages/observables/CHANGELOG.md +++ b/packages/observables/CHANGELOG.md @@ -1,5 +1,12 @@ # Project Changelog +# [@rxjs-collection/observables-v1.0.5](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/observables-v1.0.4...@rxjs-collection/observables-v1.0.5) (2024-11-24) + + +### Bug Fixes + +* **operators:** cleanup and standardize tests ([aabbbd8](https://github.com/basics/rxjs-collection/commit/aabbbd89bd76ca57cfd20b747890fcc74ee01227)) + # [@rxjs-collection/observables-v1.0.5-beta.1](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/observables-v1.0.4...@rxjs-collection/observables-v1.0.5-beta.1) (2024-11-24) diff --git a/packages/observables/package.json b/packages/observables/package.json index 49d1813..c24571d 100644 --- a/packages/observables/package.json +++ b/packages/observables/package.json @@ -1,6 +1,6 @@ { "name": "@rxjs-collection/observables", - "version": "1.0.5-beta.1", + "version": "1.0.5", "description": "rxjs observables", "license": "MIT", "contributors": [ diff --git a/packages/operators/CHANGELOG.md b/packages/operators/CHANGELOG.md index 554e598..fee2965 100644 --- a/packages/operators/CHANGELOG.md +++ b/packages/operators/CHANGELOG.md @@ -1,5 +1,17 @@ # Project Changelog +# [@rxjs-collection/operators-v1.0.6](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.5...@rxjs-collection/operators-v1.0.6) (2024-11-24) + + +### Bug Fixes + +* **deps:** pin dependencies ([fbaaf8a](https://github.com/basics/rxjs-collection/commit/fbaaf8ae9723e6960782b5cd96c2be5ce38a170c)) +* **fetch:** additional stuff ([4ab3e81](https://github.com/basics/rxjs-collection/commit/4ab3e8164d2fb347191b35e87c3ac33a2d1922f5)) +* **operators:** added fetch tests ([84b2614](https://github.com/basics/rxjs-collection/commit/84b26147bae6a8ee2a6010a0f52884900d63761e)) +* **operators:** cleanup and standardize tests ([aabbbd8](https://github.com/basics/rxjs-collection/commit/aabbbd89bd76ca57cfd20b747890fcc74ee01227)) +* **operators:** marble testing ([2b5f78b](https://github.com/basics/rxjs-collection/commit/2b5f78bacbbae30ab02f62d1e603816cadba03ee)) +* **operators:** optimized tests ([bd3c5ef](https://github.com/basics/rxjs-collection/commit/bd3c5ef521b87be36fde61e292f81e92297b16d6)) + # [@rxjs-collection/operators-v1.0.6-beta.3](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.6-beta.2...@rxjs-collection/operators-v1.0.6-beta.3) (2024-11-24) diff --git a/packages/operators/package.json b/packages/operators/package.json index 123b240..01cdf31 100644 --- a/packages/operators/package.json +++ b/packages/operators/package.json @@ -1,6 +1,6 @@ { "name": "@rxjs-collection/operators", - "version": "1.0.6-beta.3", + "version": "1.0.6", "description": "rxjs operators", "license": "MIT", "contributors": [ diff --git a/packages/operators/src/request/cache.test.js b/packages/operators/src/request/cache.test.js index bdaa853..f0af385 100644 --- a/packages/operators/src/request/cache.test.js +++ b/packages/operators/src/request/cache.test.js @@ -12,26 +12,27 @@ describe('cache', () => { }); test('default', () => { - const initial = new Response('initial', { status: 200 }); - const updated = new Response('updated', { status: 200 }); - const orderedResponses = [initial, updated]; + const expectedVal = { + a: new Response('initial', { status: 200 }), + b: new Response('updated', { status: 200 }) + }; + + const triggerVal = [expectedVal.a, expectedVal.b]; testScheduler.run(({ cold, expectObservable }) => { - const stream = cold('a', { - a: () => orderedResponses.shift() - }).pipe( + const stream = cold('a', { a: () => triggerVal.shift() }).pipe( map(fn => fn()), cache(2) ); const unsubA = '-^!'; - expectObservable(stream, unsubA).toBe('-a', { a: initial }, new Error()); + expectObservable(stream, unsubA).toBe('-a', expectedVal, new Error()); const unsubB = '----^!'; - expectObservable(stream, unsubB).toBe('----a', { a: initial }, new Error()); + expectObservable(stream, unsubB).toBe('----a', expectedVal, new Error()); const unsubC = '---------^--!'; - expectObservable(stream, unsubC).toBe('---------a', { a: updated }, new Error()); + expectObservable(stream, unsubC).toBe('---------b', expectedVal, new Error()); }); }); }); diff --git a/packages/operators/src/request/retry.test.js b/packages/operators/src/request/retry.test.js index 62b8760..16bddbd 100644 --- a/packages/operators/src/request/retry.test.js +++ b/packages/operators/src/request/retry.test.js @@ -1,6 +1,6 @@ import { map } from 'rxjs'; import { TestScheduler } from 'rxjs/testing'; -import { afterEach, beforeEach, describe, expect, test } from 'vitest'; +import { beforeEach, describe, expect, test } from 'vitest'; import { log } from '../log'; import { networkRetry } from './retry'; @@ -12,28 +12,26 @@ describe('request retry', () => { testScheduler = new TestScheduler((actual, expected) => expect(actual).deep.equal(expected)); }); - afterEach(() => { - // - }); - test('2x error -> 1x success', () => { - const error = new Response('', { status: 500 }); - const success = new Response('a', { status: 200 }); - const orderedResponses = [error, error, success]; + const expectedVal = { + a: new Response('', { status: 500 }), + b: new Response('', { status: 500 }), + c: new Response('a', { status: 200 }) + }; + + const triggerVal = [expectedVal.a, expectedVal.b, expectedVal.c]; testScheduler.run(({ cold, expectObservable }) => { // retry is repeating the sequence // if you define a delay, you have to add the delay to the subscribe multiple times (num retries) - const stream = cold('a|', { - a: () => orderedResponses.shift() - }).pipe( + const stream = cold('a|', { a: () => triggerVal.shift() }).pipe( map(fn => fn()), networkRetry({ timeout: () => 5 }), log('marble:result') ); const unsubA = '^-----------'; - expectObservable(stream, unsubA).toBe('----------a|', { a: success }); + expectObservable(stream, unsubA).toBe('----------c|', expectedVal); }); }); });