Piotr PiotrowskiandGitHub e1f12bbf4b [FIXED] Deadlock when accessing subscriptions map on consumer (#1671) ...

This fixes an issue where a deadlock could occur when calling `Stop()` or
`Drain()` on `ConsumeContext` or `MessagesContext` and then calling `Consume` or
`Messages` immediately.
Switched to using a type-safe implementation of `sync.Map` for subscriptions map
instead of locking the whole consumer state.
Additionally, changed the type of atomic flags from `uint32` to `atomic.UInt32`
to avoid accidental non-atomic reads/writes.

Signed-off-by: Piotr Piotrowski <[email protected]>

---------

Signed-off-by: Piotr Piotrowski <[email protected]>

2024-07-25 10:29:43 +02:00

..

parser

Update dates in licence headers (#1445)

2023-10-17 18:44:27 +02:00

syncx

[FIXED] Deadlock when accessing subscriptions map on consumer (#1671)

2024-07-25 10:29:43 +02:00