sern/handler
1
0
Fork 0
mirror of https://github.com/sern-handler/handler synced 2026-06-27 18:22:14 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix text compile

Browse Source
This commit is contained in:
Jacob Nguyen
2024-04-28 21:20:36 -05:00
parent 6105f7b4ef
commit 68c5f09b46
5 changed files with 15 additions and 49 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/core/module-loading.ts
View File

@@ -13,6 +13,7 @@ export const parseCallsite = (fpath: string) => {
return { name: pathobj.name,
absPath : path.posix.format(pathobj) }
}
export const shouldHandle = (pth: string, filenam: string) => {
const file_name = filenam+path.extname(pth);
let newPath = path.join(path.dirname(pth), file_name)
@@ -22,7 +23,6 @@ export const shouldHandle = (pth: string, filenam: string) => {
}
export type ModuleResult<T> = Promise<ImportPayload<T>>;
/**
* Import any module based on the absolute path.

15
src/core/operators.ts
View File

@@ -51,14 +51,13 @@ export const arrayifySource = map(src => (Array.isArray(src) ? (src as unknown[]
/**
* Checks if the stream of results is all ok.
*/
export const everyPluginOk: OperatorFunction<VoidResult, boolean> = pipe(
every(result => result.isOk()),
defaultIfEmpty(true),
);
export const everyPluginOk: OperatorFunction<VoidResult, boolean> =
pipe(every(result => result.isOk()),
defaultIfEmpty(true));
export const sharedEventStream = <T>(e: Emitter, eventName: string) =>
(fromEvent(e, eventName) as Observable<T>).pipe(share());
export const sharedEventStream = <T>(e: Emitter, eventName: string) => {
return (fromEvent(e, eventName) as Observable<T>).pipe(share());
};
export function handleError<C>(crashHandler: ErrorHandling, emitter: Emitter, logging?: Logging) {
return (pload: unknown, caught: Observable<C>) => {
@@ -80,5 +79,3 @@ export const filterTap = <K, R>(onErr: (e: R) => void): OperatorFunction<Result<
onErr(result.error);
return EMPTY
}))