add EventSource.never

bordoley · Mar 5, 2025 · 05c39bb · 05c39bb
1 parent 59d1404
commit 05c39bb
Show file tree

Hide file tree

Showing 15 changed files with 62 additions and 19 deletions.
diff --git a/docs/computations/interfaces/ConcurrentReactiveComputationModule.md b/docs/computations/interfaces/ConcurrentReactiveComputationModule.md
diff --git a/docs/concurrent/Observable/functions/never.md b/docs/concurrent/Observable/functions/never.md
diff --git a/docs/concurrent/Observable/interfaces/ObservableModule.md b/docs/concurrent/Observable/interfaces/ObservableModule.md
diff --git a/docs/events/EventSource/README.md b/docs/events/EventSource/README.md
diff --git a/docs/events/EventSource/functions/never.md b/docs/events/EventSource/functions/never.md
diff --git a/mod/computations.d.ts b/mod/computations.d.ts
diff --git a/mod/concurrent/Observable.d.ts b/mod/concurrent/Observable.d.ts
diff --git a/mod/events/EventSource.d.ts b/mod/events/EventSource.d.ts
diff --git a/mod/events/EventSource.js b/mod/events/EventSource.js
diff --git a/mod/events/EventSource/__private__/EventSource.never.d.ts b/mod/events/EventSource/__private__/EventSource.never.d.ts
diff --git a/mod/events/EventSource/__private__/EventSource.never.js b/mod/events/EventSource/__private__/EventSource.never.js
diff --git a/src/computations.ts b/src/computations.ts
@@ -823,6 +823,8 @@ export interface ConcurrentReactiveComputationModule<
     ...computations: readonly ComputationOf<TComputation, T>[]
   ): DeferredComputationWithSideEffectsOf<TComputation, T>;
 
+  never<T>(): MulticastComputationOf<TComputation, T>;
+
   withLatestFrom<TA, TB>(
     other: PureSynchronousComputationOf<TComputation, TB>,
   ): StatefulSynchronousComputationOperator<TComputation, TA, Tuple2<TA, TB>>;

diff --git a/src/concurrent/Observable.ts b/src/concurrent/Observable.ts
@@ -403,8 +403,6 @@ export interface ObservableModule
     MulticastObservableLike<T> & DisposableLike
   >;
 
-  never<T>(): MulticastObservableLike<T>;
-
   onSubscribe<T>(
     f: Factory<DisposableLike | SideEffect1<Optional<Error>>> | SideEffect,
   ): ComputationOperatorWithSideEffects<ObservableComputation, T, T>;

diff --git a/src/events/EventSource.ts b/src/events/EventSource.ts
@@ -19,6 +19,7 @@ import EventSource_fromPromise from "./EventSource/__private__/EventSource.fromP
 import EventSource_keep from "./EventSource/__private__/EventSource.keep.js";
 import EventSource_map from "./EventSource/__private__/EventSource.map.js";
 import EventSource_merge from "./EventSource/__private__/EventSource.merge.js";
+import EventSource_never from "./EventSource/__private__/EventSource.never.js";
 import EventSource_withLatestFrom from "./EventSource/__private__/EventSource.withLatestFrom.js";
 import EventSource_zipLatest from "./EventSource/__private__/EventSource.zipLatest.js";
 
@@ -64,6 +65,7 @@ export const fromPromise: Signature["fromPromise"] = EventSource_fromPromise;
 export const keep: Signature["keep"] = EventSource_keep;
 export const map: Signature["map"] = EventSource_map;
 export const merge: Signature["merge"] = EventSource_merge;
+export const never: Signature["never"] = EventSource_never;
 export const withLatestFrom: Signature["withLatestFrom"] =
   EventSource_withLatestFrom;
 export const zipLatest: Signature["zipLatest"] = EventSource_zipLatest;
diff --git a/src/events/EventSource/__private__/EventSource.never.ts b/src/events/EventSource/__private__/EventSource.never.ts
@@ -0,0 +1,10 @@
+import type * as EventSource from "../../../events/EventSource.js";
+import { ignore, returns } from "../../../functions.js";
+import EventSource_create from "./EventSource.create.js";
+
+const neverInstance = /*@__PURE__*/ EventSource_create(ignore);
+const EventSource_never: EventSource.Signature["never"] = /*@__PURE__*/ returns(
+  neverInstance,
+) as EventSource.Signature["never"];
+
+export default EventSource_never;