One consumer, one reader, however many patterns a module registers #19

2026-09-28T14:15:04Z

mesh-admin commented

2026-09-28 14:15:04 +00:00

No description provided.

jschoubben added 1 commit 2026-09-28 14:25:44 +00:00

One consumer, one reader, however many patterns a module registers 38831c5c56

A module has exactly one durable consumer, and each subscribe() started its own reader of it. Two
readers split the stream between them, and a reader that receives a message its own pattern does not
match acknowledges it — which is the right answer for a filter wider than anything registered, and
silent loss when the message was another handler's. The first module to subscribe twice would have
dropped roughly half of each kind of event with nothing reporting it.

Every registration is now dispatched from one reader, and a message is acknowledged once every handler
it is for has taken it.

jschoubben force-pushed fix/one-consumer-one-loop from f04519e3e1 to 38831c5c56

2026-09-28 14:25:44 +00:00

Compare

mesh-admin merged commit 621d033d53 into main

2026-09-28 14:25:47 +00:00

Sign in to join this conversation.

2 Participants

Notifications

Due Date

No due date set.

Dependencies

No dependencies set.

Reference: novox/mesh-tools#19