Taras Voinarovskyi

Release 0.6 planned changes

3

Will try to summarise the changes, that are planned (At least I want to do) for 0.6: - [ ] Rewrite the test suite into py.test. - [ ] Add...

Need for more FlowControl?

1

Seems like Rabbitmq has a [FlowControl](https://www.rabbitmq.com/flow-control.html) system. I didn't work to much with Rabbitmq, so I don't know much about it. Apart from that the [rabbitmq spec](https://www.rabbitmq.com/amqp-0-9-1-reference.html#channel.flow) says that there...

Refactor the return handler

1

Currently the return handler ( `Channel.set_return_handler` ) has a strange default. From docs: ``` By default, an exception is raised, which will be handled by the event loop’s exception handler...

The usecase I want to cover is like so: ``` Python import asyncio import asynqp @asyncio.coroutine def main_coro(loop): # connect to the RabbitMQ broker connection = yield from asynqp.connect( 'localhost',...

Remove QueuedReader and fix method cancellation

2

As I stated in #52 fixing the cancellation issue without removing `reader` is too hard. I've gone through the code base. The `Reader` is responsible for synchronous consumption of frames,...

Coroutines crash when are cancelled

3

Basically the Synchroniser must discard cancelled futures. Example: ``` python import asyncio import asynqp @asyncio.coroutine def main_coro(loop): # connect to the RabbitMQ broker connection = yield from asynqp.connect( 'localhost', 5672,...

Added QueuedConsumer implementation

2

With Python3.5 support for async with and async for. NOTE: There are no tests for it. Can't wrap my head around how to implement a separate test for python35, any...

Indempotent Producer implementation

7

Before working on #1063 we can implement the `enable_idempotence` option on Producer. Related KAFKA issue: [KAFKA-4817](https://issues.apache.org/jira/browse/KAFKA-4817). As it's already delivered and I want to finish both at the same time...

This part: ``` Python try: yield from self._execute_command(COMMAND.COM_PING, "") yield from self._read_ok_packet() except Exception: ``` In ping function will result in strange behavior on cancelling coroutine. CancelledError should be propagated...