feat(command-flow): move rxjs operators to core/rxjs

Author: Char2sGu

packages/command-flow/process-flow/src/facade.ts

@@ -5,8 +5,8 @@ import {
   CommandBus,
   CommandEventBus,
   CommandFlowScheduler,
-  pickType,
 } from '@angularity/command-flow';
+import { pickType } from '@angularity/core/rxjs';
 import {
   filter,
   firstValueFrom,

packages/command-flow/query-flow/src/handler.ts

@@ -1,9 +1,6 @@
 import { inject, Type } from '@angular/core';
-import {
-  CommandBus,
-  pickType,
-  registerCommandHandler,
-} from '@angularity/command-flow';
+import { CommandBus, registerCommandHandler } from '@angularity/command-flow';
+import { pickType } from '@angularity/core/rxjs';
 import { filter, mergeMap, Observable, takeUntil } from 'rxjs';
 
 import { DisposeQuery } from './commands';

packages/command-flow/src/handlers.ts

@@ -1,10 +1,10 @@
 import { inject, Type } from '@angular/core';
 import { takeUntilDestroyed } from '@angular/core/rxjs-interop';
+import { pickType } from '@angularity/core/rxjs';
 import { Observable, tap } from 'rxjs';
 
 import { CommandBus, CommandEventBus } from './buses';
 import { Command, CommandEvent } from './core';
-import { pickType } from './operators';
 import { CommandFlowScheduler } from './scheduler';
 
 export interface CommandHandler<C extends Command> {

packages/command-flow/src/public-api.ts

@@ -2,5 +2,4 @@ export * from './buses';
 export * from './core';
 export * from './facade';
 export * from './handlers';
-export * from './operators';
 export * from './scheduler';

packages/core/package.json

@@ -2,7 +2,8 @@
   "name": "@angularity/core",
   "version": "0.2.1",
   "peerDependencies": {
-    "@angular/core": "17.x.x"
+    "@angular/core": "17.x.x",
+    "rxjs": "7.x.x"
   },
   "dependencies": {
     "tslib": "2.x.x"

packages/core/rxjs/ng-package.json

@@ -0,0 +1,6 @@
+{
+  "$schema": "../../../node_modules/ng-packagr/ng-package.schema.json",
+  "lib": {
+    "entryFile": "src/public-api.ts"
+  }
+}

packages/command-flow/src/operators.ts packages/core/rxjs/src/operators.tspackages/command-flow/src/operators.ts renamed to packages/core/rxjs/src/operators.ts

@@ -0,0 +1 @@
+export * from './operators';

packages/core/rxjs/src/public-api.ts

@@ -26,6 +26,7 @@
       "@angularity/command-flow/*": ["./dist/command-flow/*"],
       "@angularity/config-files": ["./dist/config-files"],
       "@angularity/core": ["./dist/core"],
+      "@angularity/core/*": ["./dist/core/*"],
       "@angularity/endpoints": ["./dist/endpoints"],
       "@angularity/fire": ["./dist/fire"],
       "@angularity/forms": ["./dist/forms"],