createEffect.forValue() renamed to getEffectFor().

CHANGELOG.md

@@ -1,3 +1,6 @@
+### 4.2.2
+`createEffect.forValue()` renamed to `getEffectFor()`.
+
 ### 4.2.1
 Experimental method for `createEffect()`: `forValue()`, which takes a value and returns an observable that will execute the effect when subscribed.
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ngx-collection",
-  "version": "4.2.1",
+  "version": "4.2.2",
   "license": "MIT",
   "author": {
     "name": "Evgeniy OZ",

projects/ngx-collection/package.json

@@ -1,6 +1,6 @@
 {
   "name": "ngx-collection",
-  "version": "4.2.1",
+  "version": "4.2.2",
   "license": "MIT",
   "author": {
     "name": "Evgeniy OZ",
@@ -17,7 +17,7 @@
   ],
   "private": false,
   "peerDependencies": {
-    "@angular/core": "^17 || ^18 || ~19.0.0-next.2",
+    "@angular/core": "^17 || ^18 || ~19.0.0-next.3",
     "rxjs": "^7 || ^8"
   },
   "devDependencies": {

projects/ngx-collection/src/lib/create-effect.ts

@@ -17,7 +17,7 @@ export type CreateEffectOptions = {
 export type EffectMethods<ObservableType> = {
   next$: Observable<unknown>,
   error$: Observable<unknown>,
-  forValue: (observableOrValue?: ObservableType | Observable<ObservableType> | Signal<ObservableType>) => Observable<unknown>,
+  getEffectFor: (observableOrValue?: ObservableType | Observable<ObservableType> | Signal<ObservableType>) => Observable<unknown>,
 };
 
 export type EffectListeners = {
@@ -141,8 +141,8 @@ export function createEffect<
     configurable: false
   });
 
-  Object.defineProperty(effectFn, 'forValue', {
-    get: () => (observableOrValue?: ObservableType | Observable<ObservableType> | Signal<ObservableType>) => () => {
+  Object.defineProperty(effectFn, 'getEffectFor', {
+    get: () => (observableOrValue?: ObservableType | Observable<ObservableType> | Signal<ObservableType>) => {
       const observable$ = isObservable(observableOrValue)
         ? observableOrValue
         : (isSignal(observableOrValue)

projects/ngx-collection/src/lib/tests/create-effect.spec.ts

@@ -1,6 +1,6 @@
 import { signal } from "@angular/core";
 import { TestBed } from "@angular/core/testing";
-import { EMPTY, of, Subject, switchMap, tap, throwError } from "rxjs";
+import { EMPTY, isObservable, of, Subject, switchMap, tap, throwError } from "rxjs";
 import { createEffect } from '../create-effect';
 
 describe('createEffect', () => {
@@ -135,5 +135,12 @@ describe('createEffect', () => {
     TestBed.flushEffects();
     expect(lastResult).toEqual('c');
     expect(lastError).toEqual(undefined);
-  })
+  });
+
+  it('should return an observable when getEffectFor() is called', () => {
+    const e = effect.getEffectFor('test');
+    expect(isObservable(e)).toEqual(true);
+    e.subscribe();
+    expect(lastResult).toEqual('test');
+  });
 });