Artur Mruk

Cannot reconnect after connection is lost due to PING

1

When the server in not available for some time, `_close_due_to_ping` is called due to PING failure. This method calls `_close`, which has a following docstring : `"""Removes any present internal...

Configurable concurrency level for messages processing

2

I have encountered some limitations of the client, I would like to set how many concurrent tasks can be created simultaneously for the subscription. Currently it can be either one...

Configurable concurrency level for messages processing

8

This PR adds `max_cb_concurrency` parameter to `subscribe` method. Concurrent cb execution limit is achieved using `asyncio.Semaphore`. TO DISCUSS: - [x] What should be a default max concurrency parameter - [x]...