const myBackgroundProccess = Effect.async<void, never>((resume) => {
console.log("[Logging]: Starting listener")
new Promise((resolve, reject) => {
setTimeout(() => {
resolve(undefined)
}, 60000)
}).then(() => {
console.log("[Logging]: Listener finished")
resume(Effect.succeed(undefined))
})
})
export const LiveLayer = Layer.empty.pipe(
Layer.tap(ctx => myBackgroundProccess),
Layer.provideMerge(DatabaseLive),
)
const myBackgroundProccess = Effect.async<void, never>((resume) => {
console.log("[Logging]: Starting listener")
new Promise((resolve, reject) => {
setTimeout(() => {
resolve(undefined)
}, 60000)
}).then(() => {
console.log("[Logging]: Listener finished")
resume(Effect.succeed(undefined))
})
})
export const LiveLayer = Layer.empty.pipe(
Layer.tap(ctx => myBackgroundProccess),
Layer.provideMerge(DatabaseLive),
)