@@ -43,6 +43,11 @@ const ComponentProto = Object.freeze({
|
|||||||
},
|
},
|
||||||
} as const)
|
} as const)
|
||||||
|
|
||||||
|
const defaultOptions = {
|
||||||
|
finalizerExecutionMode: "sync",
|
||||||
|
finalizerExecutionStrategy: ExecutionStrategy.sequential,
|
||||||
|
} as const
|
||||||
|
|
||||||
const makeWithDefaults = (): Component<any, any, any> => Object.assign(
|
const makeWithDefaults = (): Component<any, any, any> => Object.assign(
|
||||||
Object.setPrototypeOf(function() {}, ComponentProto), {
|
Object.setPrototypeOf(function() {}, ComponentProto), {
|
||||||
finalizerExecutionMode: "sync",
|
finalizerExecutionMode: "sync",
|
||||||
@@ -290,29 +295,38 @@ export const make: (
|
|||||||
) = (spanNameOrBody: Function | string, ...pipeables: any[]): any => {
|
) = (spanNameOrBody: Function | string, ...pipeables: any[]): any => {
|
||||||
if (typeof spanNameOrBody !== "string") {
|
if (typeof spanNameOrBody !== "string") {
|
||||||
const displayName = displayNameFromBody(spanNameOrBody)
|
const displayName = displayNameFromBody(spanNameOrBody)
|
||||||
return Object.assign(makeWithDefaults(), {
|
return Object.setPrototypeOf(
|
||||||
body: displayName
|
Object.assign(function() {}, {
|
||||||
? Effect.fn(displayName)(spanNameOrBody as any, ...pipeables as [])
|
body: displayName
|
||||||
: Effect.fn(spanNameOrBody as any, ...pipeables),
|
? Effect.fn(displayName)(spanNameOrBody as any, ...pipeables as [])
|
||||||
displayName,
|
: Effect.fn(spanNameOrBody as any, ...pipeables),
|
||||||
})
|
displayName,
|
||||||
|
}),
|
||||||
|
ComponentProto,
|
||||||
|
)
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
const spanOptions = pipeables[0]
|
const spanOptions = pipeables[0]
|
||||||
return (body: any, ...pipeables: any[]) => Object.assign(makeWithDefaults(), {
|
return (body: any, ...pipeables: any[]) => Object.setPrototypeOf(
|
||||||
body: Effect.fn(spanNameOrBody, spanOptions)(body, ...pipeables as []),
|
Object.assign(function() {}, {
|
||||||
displayName: displayNameFromBody(body) ?? spanNameOrBody,
|
body: Effect.fn(spanNameOrBody, spanOptions)(body, ...pipeables as []),
|
||||||
})
|
displayName: displayNameFromBody(body) ?? spanNameOrBody,
|
||||||
|
}),
|
||||||
|
ComponentProto,
|
||||||
|
)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export const makeUntraced: make.Gen & make.NonGen = (
|
export const makeUntraced: make.Gen & make.NonGen = (
|
||||||
body: Function,
|
body: Function,
|
||||||
...pipeables: any[]
|
...pipeables: any[]
|
||||||
) => Object.assign(makeWithDefaults(), {
|
) => Object.setPrototypeOf(
|
||||||
body: Effect.fnUntraced(body as any, ...pipeables as []),
|
Object.assign(function() {}, {
|
||||||
displayName: displayNameFromBody(body),
|
body: Effect.fnUntraced(body as any, ...pipeables as []),
|
||||||
}, ComponentProto)
|
displayName: displayNameFromBody(body),
|
||||||
|
}),
|
||||||
|
ComponentProto,
|
||||||
|
)
|
||||||
|
|
||||||
const displayNameFromBody = (body: Function) => !String.isEmpty(body.name) ? body.name : undefined
|
const displayNameFromBody = (body: Function) => !String.isEmpty(body.name) ? body.name : undefined
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user