From 15511a4868841aa5205ed5efb45dacb4949d0d99 Mon Sep 17 00:00:00 2001 From: Jacob Nguyen <76754747+jacoobes@users.noreply.github.com> Date: Mon, 20 May 2024 00:49:51 -0500 Subject: [PATCH] porg --- src/core/operators.ts | 1 - src/handlers/event-utils.ts | 6 +++--- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/src/core/operators.ts b/src/core/operators.ts index 77fa257..2d06a90 100644 --- a/src/core/operators.ts +++ b/src/core/operators.ts @@ -30,7 +30,6 @@ export const arrayifySource = (src: T) => export const sharedEventStream = (e: Emitter, eventName: string) => (fromEvent(e, eventName) as Observable).pipe(share()); - export function handleError(crashHandler: ErrorHandling, emitter: Emitter, logging?: Logging) { return (pload: unknown, caught: Observable) => { // This is done to fit the ErrorHandling contract diff --git a/src/handlers/event-utils.ts b/src/handlers/event-utils.ts index e8e3621..34264d5 100644 --- a/src/handlers/event-utils.ts +++ b/src/handlers/event-utils.ts @@ -197,10 +197,10 @@ export function executeModule( /** * A higher order function that - * - creates a stream of {@link VoidResult} { config.createStream } - * - any failures results to { config.onFailure } being called + * - calls all control plugins. + * - any failures results to { config.onStop } being called * - if all results are ok, the stream is converted to { config.onNext } - * emit config.onSuccess Observable + * config.onNext will be returned if everything is okay. * @param config * @returns receiver function for flattening a stream of data */