Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

fix async watcher for libev_connection

  • Loading branch information...
commit 0d68dee19ee6ae1a51f7fb57a1b47206d45c6882 1 parent 4adc88b
@michaelplaing michaelplaing authored
Showing with 5 additions and 1 deletion.
  1. +5 −1 pika/adapters/libev_connection.py
View
6 pika/adapters/libev_connection.py
@@ -144,7 +144,8 @@ def _adapter_connect(self):
self._PIKA_TO_LIBEV_ARRAY[self.event_state],
self._handle_events)
- self.async = pyev.Async(self.ioloop, self._handle_events)
+ self.async = pyev.Async(self.ioloop, self._noop_callable)
+ self.async.start()
if self._on_signal_callback:
global_sigterm_watcher.start()
if self._on_signal_callback:
@@ -152,6 +153,9 @@ def _adapter_connect(self):
self._io_watcher.start()
return error
+
+ def _noop_callable(self, *args, **kwargs):
+ pass
def _init_connection_state(self):
"""Initialize or reset all of our internal state variables for a given
Please sign in to comment.
Something went wrong with that request. Please try again.