Merge f50843c into f79f50b

.travis.yml

@@ -7,8 +7,6 @@ language: python
 
 matrix:
   include:
-    - python: 3.4
-      env: TOXENV=py34
     - python: 3.5
       env: TOXENV=py35
     - python: 3.6

aio_pika/__init__.py

@@ -6,7 +6,10 @@
 from .queue import Queue
 from .robust_connection import connect_robust
 from .exceptions import AMQPException, MessageProcessError
-from .version import __author__, __version__, author_info, package_info, package_license, version_info
+from .version import (
+    __author__, __version__, author_info, package_info,
+    package_license, version_info
+)
 
 
 __all__ = (

aio_pika/adapter.py

@@ -190,18 +190,23 @@ def _on_channel_cancel(self, channel):
     def _create_channel(self, channel_number, on_open_callback):
         log.debug('Creating channel %s', channel_number)
         channel = Channel(self, channel_number, on_open_callback)
-        channel.add_on_cancel_callback(lambda method_frame: self._on_channel_cancel(channel))
+        channel.add_on_cancel_callback(
+            lambda method_frame: self._on_channel_cancel(channel)
+        )
         return channel
 
 
 class Channel(channel.Channel):
     def __init__(self, connection, channel_number, on_open_callback=None):
-        super().__init__(connection, channel_number, on_open_callback=on_open_callback)
+        super().__init__(connection, channel_number,
+                         on_open_callback=on_open_callback)
         self._consume_results = {}
         self._on_getempty_callback = None
 
     def _on_eventok(self, method_frame):
-        callback = self._consume_results.pop(method_frame.method.consumer_tag, None)
+        callback = self._consume_results.pop(
+            method_frame.method.consumer_tag, None
+        )
 
         if callback:
             callback(method_frame)