porg

src/core/operators.ts

@@ -30,7 +30,6 @@ export const arrayifySource = <T>(src: T) =>
 export const sharedEventStream = <T>(e: Emitter, eventName: string) => 
     (fromEvent(e, eventName) as Observable<T>).pipe(share());
 
-
 export function handleError<C>(crashHandler: ErrorHandling, emitter: Emitter, logging?: Logging) {
     return (pload: unknown, caught: Observable<C>) => {
         // This is done to fit the ErrorHandling contract

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
  */