-
Notifications
You must be signed in to change notification settings - Fork 84
[WIP] transition to anyio #302
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
Closed
Closed
Changes from 29 commits
Commits
Show all changes
42 commits
Select commit
Hold shift + click to select a range
1a78845
Ignore Debian subdir
smurfix 5a49d1f
Use a UUID for client testing against the mosquitto server
smurfix eca0b61
Use anyio, and tasks instead of threading.
smurfix a7f6dad
Test with asyncio *and* trio
smurfix dff80a5
Allow using a Unix socket (paho-mqtt 2.1)
smurfix c7d66c6
Topic comparison: don't recurse
smurfix e545ee9
Topics: pre-split
smurfix 5a5e64b
Topic: refactor
smurfix 1666ef5
Add a message subscription method.
smurfix 1c2d765
Drop the $share/<foo> prefix from the wildcard tuples up front
smurfix 4e95f24
docstring update
smurfix 53ec75c
MQTT says not to match $foo with wildcards
smurfix 08eead0
Test non-matching $foo
smurfix fc86cac
Also filter $foo in straight-up topic matches
smurfix 8cae372
Add tests for $foo topic matches
smurfix d72f3a0
Fix test_messages_generator_is_reusable
smurfix f66d405
test_client: don't use anyio.wait_all_tasks_blocked
smurfix d7363d1
test_client_unsubscribe: fix race condition
smurfix db68cbd
Cleanly close queues
smurfix e03b730
drop dead code
smurfix f86a007
Basic split subscription handling
smurfix 6ef44ce
Fix unsubscription
smurfix 9bc237f
stupid logic error
smurfix b403430
Prepare for handling errors in SubscriptionTree.attach
smurfix e10d7a9
Raise an error if a specific subscription already exists
smurfix 604ed19
Simplify auto-unsubscribe code
smurfix 89baab4
Extend subscription test
smurfix 2c28b7f
Use subscription identifiers, if supported
smurfix cb20faf
Always test the fallback dispatch code
smurfix ef9868f
Client.subscription: optionally pass a queue in
smurfix c643f2d
Typo
smurfix ab969bb
Handle asyncio queues
smurfix 9c6a7f4
Document new features
smurfix bc6dad8
Initial ruff-format-ting
smurfix 170d234
Our queue wrapper depends on outcome
smurfix 83c43e5
Remove dependency on attrs
smurfix b35e957
Merge tag 'v2.3.0'
smurfix 37bffbd
Use non-reimported constants
smurfix deeb7fc
Event, not Future
smurfix 52457c2
Make test host+port(s) semi-overrideable
smurfix 4aa26c1
no asyncio please
smurfix 5f658d9
Fix the global "messages" iterator
smurfix File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -11,3 +11,6 @@ aiomqtt/_version.py | |
*.DS_Store | ||
docs/_build | ||
reports | ||
|
||
# Debian packaging | ||
/debian/ |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.