Commit 9151e1a
committed
feat(effect): add durable message queue processing to Counter actor
Add Message.make definitions (Reset, IncrementBy) alongside existing
actions, and implement pull-based queue processing via Queue.take with
Match.exhaustive pattern matching in a forked scoped fiber.1 parent e628723 commit 9151e1a
3 files changed
Lines changed: 54 additions & 11 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.
0 commit comments