fix(operators): restructured and added aliases

Author: StephanGerbeth

packages/mock/async.js renamed to packages/mocks/async.js

@@ -17,6 +17,9 @@
   "scripts": {
     "release": "npx semantic-release"
   },
+  "imports": {
+    "#mocks/*": "../mocks/*"
+  },
   "dependencies": {
     "@rxjs-collection/operators": "*",
     "rxjs": "7.8.1"

packages/mock/network.js renamed to packages/mocks/network.js

@@ -1,8 +1,8 @@
+import { mockOffline, mockOnline, mockReset } from '#mocks/network.js';
 import { tap } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { beforeEach, test, expect, describe, afterEach } from 'vitest';
 
-import { mockOffline, mockOnline, mockReset } from '../../../mock/network.js';
 import { connectionObservable } from './window.js';
 
 // HINT: https://betterprogramming.pub/rxjs-testing-write-unit-tests-for-observables-603af959e251

packages/mock/response.js renamed to packages/mocks/response.js

@@ -17,6 +17,10 @@
   "scripts": {
     "release": "npx semantic-release"
   },
+  "imports": {
+    "#observables/*": "../observables/src/*",
+    "#mocks/*": "../mocks/*"
+  },
   "dependencies": {
     "@rxjs-collection/observables": "*",
     "ansi-colors": "4.1.3",

packages/observables/package.json

@@ -0,0 +1,14 @@
+export { autoPagination } from './request/autoPagination';
+export { cache } from './request/cache';
+export { concurrentRequest } from './request/concurrentRequest';
+export { lazyPagination } from './request/lazyPagination';
+export { polling } from './request/polling';
+export { request, requestJSON, requestText, requestBlob } from './request/request';
+export {
+  resolve,
+  resolveJSON,
+  resolveText,
+  resolveBlob,
+  distinctUntilResponseChanged
+} from './request/response';
+export { retryWhenError } from './request/retry';

packages/observables/src/dom/window.test.js

@@ -1,9 +1,9 @@
+import { mockAsync } from '#mocks/async';
+import { mockResponse } from '#mocks/response';
 import { concatAll, delay, from, map, of } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { afterAll, beforeAll, beforeEach, describe, expect, test, vi } from 'vitest';
 
-import { mockAsync } from '../../../mock/async';
-import { mockResponse } from '../../../mock/response';
 import { log, logResult } from '../log';
 import { resolveJSON } from './response';
 

packages/operators/package.json

@@ -1,9 +1,9 @@
+import { mockAsync } from '#mocks/async';
+import { mockResponse } from '#mocks/response';
 import { concatAll, delay, map, of } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { afterAll, beforeAll, beforeEach, describe, expect, test, vi } from 'vitest';
 
-import { mockAsync } from '../../../mock/async';
-import { mockResponse } from '../../../mock/response';
 import { log, logResult } from '../log';
 import { resolveJSON, resolveText } from './response';
 

packages/operators/src/index.js

@@ -1,9 +1,9 @@
+import { mockAsync } from '#mocks/async';
+import { mockResponse } from '#mocks/response';
 import { concatAll, delay, map, of, Subject, tap } from 'rxjs';
 import { TestScheduler } from 'rxjs/testing';
 import { afterAll, beforeAll, beforeEach, describe, expect, test, vi } from 'vitest';
 
-import { mockAsync } from '../../../mock/async';
-import { mockResponse } from '../../../mock/response';
 import { log, logResult } from '../log';
 import { resolveJSON } from './response';