Fixed deprecation warnings:

gevent.queue.Queue(0) now means infinity queue, changing to Channel instead.
gevent.coros module deprecated in favor of gevent.lock

.gitignore

@@ -5,3 +5,4 @@ dist/
 *.egg
 *.egg-info
 .tox
+.idea

zerorpc/channel.py

@@ -28,7 +28,7 @@
 import gevent.queue
 import gevent.event
 import gevent.local
-import gevent.coros
+import gevent.lock
 
 from .exceptions import TimeoutExpired
 

zerorpc/core.py

@@ -29,7 +29,7 @@
 import gevent.queue
 import gevent.event
 import gevent.local
-import gevent.coros
+import gevent.lock
 
 import gevent_zmq as zmq
 from .exceptions import TimeoutExpired, RemoteError, LostRemote

zerorpc/events.py

@@ -28,7 +28,7 @@
 import gevent.queue
 import gevent.event
 import gevent.local
-import gevent.coros
+import gevent.lock
 
 
 import gevent_zmq as zmq
@@ -39,7 +39,7 @@ class Sender(object):
 
     def __init__(self, socket):
         self._socket = socket
-        self._send_queue = gevent.queue.Queue(maxsize=0)
+        self._send_queue = gevent.queue.Channel()
         self._send_task = gevent.spawn(self._sender)
 
     def __del__(self):
@@ -72,7 +72,7 @@ class Receiver(object):
 
     def __init__(self, socket):
         self._socket = socket
-        self._recv_queue = gevent.queue.Queue(maxsize=0)
+        self._recv_queue = gevent.queue.Channel()
         self._recv_task = gevent.spawn(self._recver)
 
     def __del__(self):

zerorpc/heartbeat.py

@@ -28,7 +28,7 @@
 import gevent.queue
 import gevent.event
 import gevent.local
-import gevent.coros
+import gevent.lock
 
 from .exceptions import *
 
@@ -38,7 +38,7 @@ class HeartBeatOnChannel(object):
     def __init__(self, channel, freq=5, passive=False):
         self._channel = channel
         self._heartbeat_freq = freq
-        self._input_queue = gevent.queue.Queue(maxsize=0)
+        self._input_queue = gevent.queue.Channel()
         self._remote_last_hb = None
         self._lost_remote = False
         self._recv_task = gevent.spawn(self._recver)