Effect.gen(function* ($) {
const changeFeed = yield* $(PubSub.unbounded<null | string>())
const q = yield* $(PubSub.subscribe(changefeed))
yield* $(Queue.take(q).pipe(Effect.tap(v => Effect.logInfo("hello " + v)), Effect.forever, Effect.fork))
yield* $(PubSub.publish(null)) // replace null with "there", and it works
yield* $(Effect.sleep("1 hours"))
})
Effect.gen(function* ($) {
const changeFeed = yield* $(PubSub.unbounded<null | string>())
const q = yield* $(PubSub.subscribe(changefeed))
yield* $(Queue.take(q).pipe(Effect.tap(v => Effect.logInfo("hello " + v)), Effect.forever, Effect.fork))
yield* $(PubSub.publish(null)) // replace null with "there", and it works
yield* $(Effect.sleep("1 hours"))
})
