Merge pull request #95 from basics/beta

Beta

Author: StephanGerbeth

package-lock.json

@@ -10,7 +10,7 @@
     }
   ],
   "type": "module",
-  "main": "index.js",
+  "main": "src/index.js",
   "files": [
     "./src/*"
   ],

packages/observables/index.js

@@ -0,0 +1 @@
+export { connectionObservable } from './dom/window';

packages/observables/package.json

@@ -1,5 +1,14 @@
 # Project Changelog
 
+# [@rxjs-collection/operators-v1.0.11-beta.1](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.10...@rxjs-collection/operators-v1.0.11-beta.1) (2024-11-26)
+
+
+### Bug Fixes
+
+* **operators:** cleanup & optimization ([200b476](https://github.com/basics/rxjs-collection/commit/200b476d02deb96764bb43e4e7573855e2af5c92))
+* **operators:** fix cache log ([c551158](https://github.com/basics/rxjs-collection/commit/c5511580b60c5ce1b595dd7541edcc32aa97a445))
+* **operators:** solved duplication ([eae508b](https://github.com/basics/rxjs-collection/commit/eae508b7fe2a43879d1ba46df9d17d9e632f8778))
+
 # [@rxjs-collection/operators-v1.0.10](https://github.com/basics/rxjs-collection/compare/@rxjs-collection/operators-v1.0.9...@rxjs-collection/operators-v1.0.10) (2024-11-25)
 
 

packages/observables/src/index.js

@@ -1,6 +1,6 @@
 {
   "name": "@rxjs-collection/operators",
-  "version": "1.0.10",
+  "version": "1.0.11-beta.1",
   "description": "rxjs operators",
   "license": "MIT",
   "contributors": [
@@ -10,7 +10,7 @@
     }
   ],
   "type": "module",
-  "main": "index.js",
+  "main": "src/index.js",
   "files": [
     "./src/*"
   ],

packages/operators/CHANGELOG.md

@@ -3,6 +3,7 @@ import { TestScheduler } from 'rxjs/testing';
 import { beforeEach, describe, expect, test } from 'vitest';
 
 import { cache } from './cache';
+import { log } from './log';
 
 describe('cache', () => {
   let testScheduler;
@@ -22,7 +23,9 @@ describe('cache', () => {
     testScheduler.run(({ cold, expectObservable }) => {
       const stream = cold('a', { a: () => triggerVal.shift() }).pipe(
         map(fn => fn()),
+        log('operators:cache:default:input'),
         cache({ ttl: 2 })
+        // log('operators:cache:default:output')
       );
 
       const unsubA = '-^!';

packages/operators/fixtures/paginatedFetchFixture.js

@@ -11,4 +11,4 @@ export {
   resolveBlob,
   distinctUntilResponseChanged
 } from './request/response';
-export { retryWhenError } from './request/retry';
+export { retryWhenRequestError } from './retry';