Skip to content

Implement async consumer #277

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
BewareMyPower merged 13 commits into from
Dec 24, 2025
+680 −28
Merged

Implement async consumer #277

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
a61c5e4
Support basic functionality of asyncio based consumer
BewareMyPower Dec 23, 2025
c232dfe
add all options
BewareMyPower Dec 23, 2025
08c6f9a
support seek and fix tests
BewareMyPower Dec 23, 2025
84c29a4
add comments
BewareMyPower Dec 23, 2025
3a6aa86
fix api docs
BewareMyPower Dec 23, 2025
1f98f44
test start_message_id_inclusive
BewareMyPower Dec 23, 2025
5f37afb
fix incorrect api doc
BewareMyPower Dec 23, 2025
ed78ac5
fix doc and remove message_listener
BewareMyPower Dec 23, 2025
e0b1de7
fail when is_pattern_topic is True and topics is a list
BewareMyPower Dec 23, 2025
a4405b8
fix incorrect schema
BewareMyPower Dec 23, 2025
2584878
fix schema tests
BewareMyPower Dec 23, 2025
4e1e42c
Remove changes not related
BewareMyPower Dec 24, 2025
75495d3
remove unused imports
BewareMyPower Dec 24, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Loading
Loading