Skip to content

Commit

Permalink
Merge branch 'master' into develop
Browse files Browse the repository at this point in the history
  • Loading branch information
aohan237 committed Nov 2, 2018
2 parents 092e73a + 411b508 commit e2376fc
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 2 deletions.
2 changes: 2 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
[![Downloads](https://pepy.tech/badge/asyncnsq)](https://pepy.tech/project/asyncnsq)

asyncnsq
=========================
async nsq with python3.6 await/async supported
Expand Down
2 changes: 1 addition & 1 deletion asyncnsq/__init__.py
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
__version__ = '0.4.4'
__version__ = '0.4.5'

import asyncio
from .utils import get_host_and_port
Expand Down
3 changes: 2 additions & 1 deletion asyncnsq/nsq.py
Original file line number Diff line number Diff line change
Expand Up @@ -120,7 +120,7 @@ async def reconnect(self):
self._host, self._port))
else:
self._status = consts.CONNECTED
t = next(timeout_generator)
t = next(timeout_generator)
await asyncio.sleep(t, loop=self._loop)

async def execute(self, command, *args, data=None):
Expand Down Expand Up @@ -250,6 +250,7 @@ async def cls(self):

def close(self):
self._conn.close()
self._status = consts.CLOSED

def is_starved(self):

Expand Down

0 comments on commit e2376fc

Please sign in to comment.