Code

[WIP] Async/Await Prototype#70

Code

Open

liamdiprose wants to merge 22 commits intowialon:masterwialon/gmqtt:masterfrom liamdiprose:awaitable-api-refactorliamdiprose/gmqtt:awaitable-api-refactorCopy head branch name to clipboard

+371

Commits

Commits on Nov 16, 2019

• Initial async-with and await API prototype

  

  Liam Diprose

  committed
  24af4e6

  Copy full SHA for 24af4e6

Commits on Nov 18, 2019

• Rename wrapper class with postfix that is used elsewhere in codebase

  liamdiprose

  committed
  27e77c3

  Copy full SHA for 27e77c3

• Allow maximum queue size to be set to prevent a possible memory overflow

  liamdiprose

  committed
  69b3b7e

  Copy full SHA for 69b3b7e

• Received messages are now the entire message object, not just the payload

  liamdiprose

  committed
  27a4e4e

  Copy full SHA for 27a4e4e

• Finish renaming ClientWrapper class

  liamdiprose

  committed
  a53d567

  Copy full SHA for a53d567

Commits on Nov 19, 2019

• Initial implementation of Subscription object-based API

  liamdiprose

  committed
  6dd3e73

  Copy full SHA for 6dd3e73

• Implement async iterator for subscription

  liamdiprose

  committed
  f109600

  Copy full SHA for f109600

• Make connect context-manager awaitable (see doctest)

  

  Liam Diprose

  committed
  09af3ec

  Copy full SHA for 09af3ec

Commits on Nov 26, 2019

• Make client_id optional

  liamdiprose

  committed
  5fe1f1f

  Copy full SHA for 5fe1f1f

Commits on Nov 27, 2019

• Simplify filling in optional parameter

  liamdiprose

  committed
  56e01b4

  Copy full SHA for 56e01b4

• Add more parameters to connect function

  liamdiprose

  committed
  ca1c613

  Copy full SHA for ca1c613

• Git-ignore mypy cache and hidden '.venv' directories

  liamdiprose

  committed
  f6a0169

  Copy full SHA for f6a0169

Commits on Nov 29, 2019

• Use named argument

  liamdiprose

  committed
  a6a7c48

  Copy full SHA for a6a7c48

• Initial implimentation of subscription manager that conforms to MQTT flow control

  liamdiprose

  committed
  1776fa9

  Copy full SHA for 1776fa9

Commits on Dec 4, 2019

• Add subscription manager for handling incoming messages

  liamdiprose

  committed
  5786fee

  Copy full SHA for 5786fee

• Add tests for alternative async/await client API

  liamdiprose

  committed
  da1dee7

  Copy full SHA for da1dee7

• Enable typechecking

  liamdiprose

  committed
  9c8624c

  Copy full SHA for 9c8624c

• Format async/await tests

  liamdiprose

  committed
  73e9e82

  Copy full SHA for 73e9e82

• Add tests for expect-duplicated messges

  liamdiprose

  committed
  da05359

  Copy full SHA for da05359

• Finish renaming recv() method

  liamdiprose

  committed
  cbf0062

  Copy full SHA for cbf0062

• Add FIXME note

  liamdiprose

  committed
  995d3d8

  Copy full SHA for 995d3d8

Commits on Mar 23, 2020

• Work with port

  liamdiprose

  committed
  d63353f

  Copy full SHA for d63353f