Code

[WIP] transition to anyio#302

Code

Closed

smurfix wants to merge 42 commits intoempicano:mainempicano/aiomqtt:mainfrom M-o-a-T:mainM-o-a-T/aiomqtt:mainCopy head branch name to clipboard

+1,940-459

Commits

Commits on May 21, 2024

• Ignore Debian subdir

  smurfix

  committed
  1a78845

  Copy full SHA for 1a78845

Commits on May 22, 2024

• Use a UUID for client testing against the mosquitto server

  smurfix

  committed
  5a49d1f

  Copy full SHA for 5a49d1f

• Use anyio, and tasks instead of threading.

  Show description for eca0b61
  smurfix

  committed
  eca0b61

  Copy full SHA for eca0b61

Commits on May 23, 2024

• Test with asyncio *and* trio

  smurfix

  committed
  a7f6dad

  Copy full SHA for a7f6dad

• Allow using a Unix socket (paho-mqtt 2.1)

  smurfix

  committed
  dff80a5

  Copy full SHA for dff80a5

• Topic comparison: don't recurse

  Show description for c7d66c6
  smurfix

  committed
  c7d66c6

  Copy full SHA for c7d66c6

• Topics: pre-split

  Show description for e545ee9
  smurfix

  committed
  e545ee9

  Copy full SHA for e545ee9

• Topic: refactor

  Show description for 5a5e64b
  smurfix

  committed
  5a5e64b

  Copy full SHA for 5a5e64b

• Add a message subscription method.

  Show description for 1666ef5
  smurfix

  committed
  1666ef5

  Copy full SHA for 1666ef5

• Drop the $share/<foo> prefix from the wildcard tuples up front

  Show description for 1c2d765
  smurfix

  committed
  1c2d765

  Copy full SHA for 1c2d765

• docstring update

  smurfix

  committed
  4e95f24

  Copy full SHA for 4e95f24

• MQTT says not to match $foo with wildcards

  smurfix

  committed
  53ec75c

  Copy full SHA for 53ec75c

• Test non-matching $foo

  smurfix

  committed
  08eead0

  Copy full SHA for 08eead0

• Also filter $foo in straight-up topic matches

  smurfix

  committed
  fc86cac

  Copy full SHA for fc86cac

• Add tests for $foo topic matches

  smurfix

  committed
  8cae372

  Copy full SHA for 8cae372

Commits on May 27, 2024

• Fix test_messages_generator_is_reusable

  Show description for d72f3a0
  smurfix

  committed
  d72f3a0

  Copy full SHA for d72f3a0

• test_client: don't use anyio.wait_all_tasks_blocked

  Show description for f66d405
  smurfix

  committed
  f66d405

  Copy full SHA for f66d405

• test_client_unsubscribe: fix race condition

  Show description for d7363d1
  smurfix

  committed
  d7363d1

  Copy full SHA for d7363d1

• Cleanly close queues

  Show description for db68cbd
  smurfix

  committed
  db68cbd

  Copy full SHA for db68cbd

• drop dead code

  smurfix

  committed
  e03b730

  Copy full SHA for e03b730

• Basic split subscription handling

  Show description for f86a007
  smurfix

  committed
  f86a007

  Copy full SHA for f86a007

• Fix unsubscription

  smurfix

  committed
  6ef44ce

  Copy full SHA for 6ef44ce

• stupid logic error

  smurfix

  committed
  9bc237f

  Copy full SHA for 9bc237f

• Prepare for handling errors in SubscriptionTree.attach

  smurfix

  committed
  b403430

  Copy full SHA for b403430

• Raise an error if a specific subscription already exists

  smurfix

  committed
  e10d7a9

  Copy full SHA for e10d7a9

• Simplify auto-unsubscribe code

  Show description for 604ed19
  smurfix

  committed
  604ed19

  Copy full SHA for 604ed19

• Extend subscription test

  Show description for 89baab4
  smurfix

  committed
  89baab4

  Copy full SHA for 89baab4

• Use subscription identifiers, if supported

  Show description for 2c28b7f
  smurfix

  committed
  2c28b7f

  Copy full SHA for 2c28b7f

• Always test the fallback dispatch code

  smurfix

  committed
  cb20faf

  Copy full SHA for cb20faf

• Client.subscription: optionally pass a queue in

  smurfix

  committed
  ef9868f

  Copy full SHA for ef9868f

Commits on May 28, 2024

• Typo

  smurfix

  committed
  c643f2d

  Copy full SHA for c643f2d

• Handle asyncio queues

  smurfix

  committed
  ab969bb

  Copy full SHA for ab969bb

• Document new features

  smurfix

  committed
  9c6a7f4

  Copy full SHA for 9c6a7f4

• Initial ruff-format-ting

  Show description for bc6dad8
  smurfix

  committed
  bc6dad8

  Copy full SHA for bc6dad8

• Our queue wrapper depends on outcome

  smurfix

  committed
  170d234

  Copy full SHA for 170d234

• Remove dependency on attrs

  Show description for 83c43e5
  smurfix

  committed
  83c43e5

  Copy full SHA for 83c43e5

Commits on Nov 5, 2024

• Merge tag 'v2.3.0'

  smurfix

  committed
  b35e957

  Copy full SHA for b35e957

• Use non-reimported constants

  smurfix

  committed
  37bffbd

  Copy full SHA for 37bffbd

• Event, not Future

  smurfix

  committed
  deeb7fc

  Copy full SHA for deeb7fc

• Make test host+port(s) semi-overrideable

  smurfix

  committed
  52457c2

  Copy full SHA for 52457c2

• no asyncio please

  smurfix

  committed
  4aa26c1

  Copy full SHA for 4aa26c1

• Fix the global "messages" iterator

  smurfix

  committed
  5f658d9

  Copy full SHA for 5f658d9