export const HealthLive = HttpApiBuilder.group(
DomainApi,
"health",
Effect.fnUntraced(function* (handlers) {
yield* Effect.log("Building health handlers")
return handlers.handle(
"health",
Effect.fn("health.health")(function* () {
const myEffect = Effect.gen(function* () {
yield* Effect.log("My effect started")
for (let i = 0; i < 10; i++) {
yield* Effect.log(`My effect ${i}`)
yield* Effect.sleep(Duration.seconds(1))
}
}).pipe(Effect.uninterruptible)
const fiber = yield* Effect.forkDaemon(myEffect)
fiber.addObserver((result) => {
console.log(result)
})
return { status: "ok" }
})
)
})
)
export const HealthLive = HttpApiBuilder.group(
DomainApi,
"health",
Effect.fnUntraced(function* (handlers) {
yield* Effect.log("Building health handlers")
return handlers.handle(
"health",
Effect.fn("health.health")(function* () {
const myEffect = Effect.gen(function* () {
yield* Effect.log("My effect started")
for (let i = 0; i < 10; i++) {
yield* Effect.log(`My effect ${i}`)
yield* Effect.sleep(Duration.seconds(1))
}
}).pipe(Effect.uninterruptible)
const fiber = yield* Effect.forkDaemon(myEffect)
fiber.addObserver((result) => {
console.log(result)
})
return { status: "ok" }
})
)
})
)