Skip to content

Implementation of the asyncio consumer #228

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

Open
wants to merge 16 commits into
base: main
Choose a base branch
from
Open

Implementation of the asyncio consumer #228

Show file tree
Hide file tree
Changes from 12 commits
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
5bbddb5
WIP: Proper asyncio implementation using the c++ side
nl-x-net Sep 17, 2024
c3b6614
Implemented missing async consumer methods in c++ and python
nl-x-net Sep 19, 2024
58b5eb5
removed uncecessary dev file
nl-x-net Sep 19, 2024
d4aab5c
Added tests for async client
nl-x-net Sep 20, 2024
cef9a76
Fixed pulsar url in tests
Nictec Sep 20, 2024
656a287
FIX: Removed binary from repo, fixed schema handling in async consumer
nl-x-net Oct 18, 2024
1c56c59
Merge remote-tracking branch 'origin/nl-full-asyncio' into nl-full-as…
nl-x-net Oct 18, 2024
1f96710
FIX: Removed debug prints
nl-x-net Oct 18, 2024
1909e40
FIX: Use python 3.8 compatible type annotations
nl-x-net Oct 30, 2024
84f1396
Merge branch 'main' into nl-full-asyncio
merlimat Nov 2, 2024
b17606c
FIX: Fixed requested changes.
nl-x-net Nov 4, 2024
031cf47
Merge remote-tracking branch 'origin/nl-full-asyncio' into nl-full-as…
nl-x-net Nov 4, 2024
e736852
Removed binary files
merlimat Dec 2, 2024
b230e84
Removed unnecessary TODO
Nictec Dec 2, 2024
93e3cb3
FIX: Fixed inconsistent c++ method implementation, removed unnecessar…
nl-x-net Dec 4, 2024
d1485b3
Merge remote-tracking branch 'origin/nl-full-asyncio' into nl-full-as…
nl-x-net Dec 4, 2024
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
Binary file added .cache/jb/UpdateWork.dat
View file
Open in desktop
Binary file not shown.
1 change: 1 addition & 0 deletions .cache/jb/version.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
(ssh://[email protected]/llvm/llvm-project.git f4157ca9dd49181f6d35eaf6d324ffa84a40f01b based on LLVM 31f1590e4fb324c43dc36199587c453e27b6f6fa revision)
Loading
Loading