Make drain() coroutine

aio-libs · Dec 20, 2014 · e71ae1c · e71ae1c
1 parent 007a296
commit e71ae1c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/aiozmq/stream.py b/aiozmq/stream.py
@@ -140,6 +140,7 @@ def close(self):
     def get_extra_info(self, name, default=None):
         return self._transport.get_extra_info(name, default)
 
+    @asyncio.coroutine
     def drain(self):
         """This method has an unusual return value.