-
Notifications
You must be signed in to change notification settings - Fork 73
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.
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
[WIP] transition to anyio #302
base: main
Are you sure you want to change the base?
Commits on May 21, 2024
-
Configuration menu - View commit details
-
Copy full SHA for 1a78845 - Browse repository at this point
Copy the full SHA 1a78845View commit details
Commits on May 22, 2024
-
Configuration menu - View commit details
-
Copy full SHA for 5a49d1f - Browse repository at this point
Copy the full SHA 5a49d1fView commit details -
Use anyio, and tasks instead of threading.
This commit subclasses the paho MQTT client code (somewhat intrusively), replacing its threading with anyio-style tasks.
Configuration menu - View commit details
-
Copy full SHA for eca0b61 - Browse repository at this point
Copy the full SHA eca0b61View commit details
Commits on May 23, 2024
-
Configuration menu - View commit details
-
Copy full SHA for a7f6dad - Browse repository at this point
Copy the full SHA a7f6dadView commit details -
Configuration menu - View commit details
-
Copy full SHA for dff80a5 - Browse repository at this point
Copy the full SHA dff80a5View commit details -
Topic comparison: don't recurse
Recursion is bad for you. More to the point it's not necessary. Also, several common non-matches can be checked for up front.
Configuration menu - View commit details
-
Copy full SHA for c7d66c6 - Browse repository at this point
Copy the full SHA c7d66c6View commit details -
Pre-split the topic so the comparison code doesn't need to run `split` each time it's called.
Configuration menu - View commit details
-
Copy full SHA for e545ee9 - Browse repository at this point
Copy the full SHA e545ee9View commit details -
Drop the trailing hash from the split wildcard topic. This further simplifies the code and prepares for the next bit.
Configuration menu - View commit details
-
Copy full SHA for 5a5e64b - Browse repository at this point
Copy the full SHA 5a5e64bView commit details -
Add a message subscription method.
Subscriptions are arranged into a tree that's traversed when a message is dispatched.
Configuration menu - View commit details
-
Copy full SHA for 1666ef5 - Browse repository at this point
Copy the full SHA 1666ef5View commit details -
Drop the $share/<foo> prefix from the wildcard tuples up front
No sense in doing this in the comparator
Configuration menu - View commit details
-
Copy full SHA for 1c2d765 - Browse repository at this point
Copy the full SHA 1c2d765View commit details -
Configuration menu - View commit details
-
Copy full SHA for 4e95f24 - Browse repository at this point
Copy the full SHA 4e95f24View commit details -
Configuration menu - View commit details
-
Copy full SHA for 53ec75c - Browse repository at this point
Copy the full SHA 53ec75cView commit details -
Configuration menu - View commit details
-
Copy full SHA for 08eead0 - Browse repository at this point
Copy the full SHA 08eead0View commit details -
Configuration menu - View commit details
-
Copy full SHA for fc86cac - Browse repository at this point
Copy the full SHA fc86cacView commit details -
Configuration menu - View commit details
-
Copy full SHA for 8cae372 - Browse repository at this point
Copy the full SHA 8cae372View commit details
Commits on May 27, 2024
-
Fix test_messages_generator_is_reusable
Use `contextlib.aclosing` to cleanly stop the iterator
Configuration menu - View commit details
-
Copy full SHA for d72f3a0 - Browse repository at this point
Copy the full SHA d72f3a0View commit details -
test_client: don't use anyio.wait_all_tasks_blocked
instead, synchronize via task_status.started()
Configuration menu - View commit details
-
Copy full SHA for f66d405 - Browse repository at this point
Copy the full SHA f66d405View commit details -
test_client_unsubscribe: fix race condition
If the server is busy it might delay forwarding messages until after it sees the unsubscription.
Configuration menu - View commit details
-
Copy full SHA for d7363d1 - Browse repository at this point
Copy the full SHA d7363d1View commit details -
Configuration menu - View commit details
-
Copy full SHA for db68cbd - Browse repository at this point
Copy the full SHA db68cbdView commit details -
Configuration menu - View commit details
-
Copy full SHA for e03b730 - Browse repository at this point
Copy the full SHA e03b730View commit details -
Basic split subscription handling
This change adds subscriptions with separate message queues. Does not yet handle duplicate subscriptions.
Configuration menu - View commit details
-
Copy full SHA for f86a007 - Browse repository at this point
Copy the full SHA f86a007View commit details -
Configuration menu - View commit details
-
Copy full SHA for 6ef44ce - Browse repository at this point
Copy the full SHA 6ef44ceView commit details -
Configuration menu - View commit details
-
Copy full SHA for 9bc237f - Browse repository at this point
Copy the full SHA 9bc237fView commit details -
Configuration menu - View commit details
-
Copy full SHA for b403430 - Browse repository at this point
Copy the full SHA b403430View commit details -
Configuration menu - View commit details
-
Copy full SHA for e10d7a9 - Browse repository at this point
Copy the full SHA e10d7a9View commit details -
Simplify auto-unsubscribe code
needs just a bool return, not a counter
Configuration menu - View commit details
-
Copy full SHA for 604ed19 - Browse repository at this point
Copy the full SHA 604ed19View commit details -
This test doesn't yet support subscribing to a topic multiple times. TODO.
Configuration menu - View commit details
-
Copy full SHA for 89baab4 - Browse repository at this point
Copy the full SHA 89baab4View commit details -
Use subscription identifiers, if supported
This change skips walking the topic tree, assuming server support.
Configuration menu - View commit details
-
Copy full SHA for 2c28b7f - Browse repository at this point
Copy the full SHA 2c28b7fView commit details -
Configuration menu - View commit details
-
Copy full SHA for cb20faf - Browse repository at this point
Copy the full SHA cb20fafView commit details -
Configuration menu - View commit details
-
Copy full SHA for ef9868f - Browse repository at this point
Copy the full SHA ef9868fView commit details
Commits on May 28, 2024
-
Configuration menu - View commit details
-
Copy full SHA for c643f2d - Browse repository at this point
Copy the full SHA c643f2dView commit details -
Configuration menu - View commit details
-
Copy full SHA for ab969bb - Browse repository at this point
Copy the full SHA ab969bbView commit details -
Configuration menu - View commit details
-
Copy full SHA for 9c6a7f4 - Browse repository at this point
Copy the full SHA 9c6a7f4View commit details -
Configuration menu - View commit details
-
Copy full SHA for bc6dad8 - Browse repository at this point
Copy the full SHA bc6dad8View commit details -
Configuration menu - View commit details
-
Copy full SHA for 170d234 - Browse repository at this point
Copy the full SHA 170d234View commit details -
turns out that it obfuscates more than it helps, at least here
Configuration menu - View commit details
-
Copy full SHA for 83c43e5 - Browse repository at this point
Copy the full SHA 83c43e5View commit details