- Nov 01, 2023
-
-
Mikhail Karnevskiy authored
-
- Oct 30, 2023
-
-
Mikhail Karnevskiy authored
-
- Sep 25, 2023
-
-
Mikhail Karnevskiy authored
-
- Sep 14, 2023
-
-
Mikhail Karnevskiy authored
get_next_available See merge request asapo/asapo!204
-
Mikhail Karnevskiy authored
Allow sending objects supporting the buffer interface Closes #7 See merge request asapo/asapo!187
-
- Sep 08, 2023
-
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
- Sep 07, 2023
-
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
- Aug 31, 2023
-
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
- Aug 30, 2023
-
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
- Aug 28, 2023
-
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
Add optional argument `ordered` to consumer function get_next. If true messages will be ordered by message_id otherwise by _id.
-
Mikhail Karnevskiy authored
Add boolean parameter `ordered` to request get_next. If True, it returns next by message_id, if not by _id.
-
Mikhail Karnevskiy authored
-
- Aug 17, 2023
-
-
Mikhail Karnevskiy authored
Speedup get_next See merge request asapo/asapo!203
-
Mikhail Karnevskiy authored
-
- Aug 10, 2023
-
-
Tim Schoof authored
-
Tim Schoof authored
-
Tim Schoof authored
-
Tim Schoof authored
This includes read-only buffers. The code split between bytes and numpy array is removed and all objects are now handled equally. Furthermore, it seems to be more correct to increase the ref count for None objects as well, while a pointer to that object is used.
-
- Aug 07, 2023
-
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
- Aug 04, 2023
-
-
Mikhail Karnevskiy authored
Enable test of receiver with kafka. Add sleep of 3 sec after start of kafka listener to ensure that is it ready
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-
Mikhail Karnevskiy authored
-