Fix _interrupt in both event loop implementations

The `_interrupt()` method was broken in both event loop implementations(it was
not stopping the event loop). This commit adds a test and fixes the bug.

Author: tarruda

neovim/msgpack_rpc/event_loop/asyncio.py

@@ -108,8 +108,7 @@ def _stop(self):
         self._loop.stop()
 
     def _interrupt(self):
-        self._loop.call_soon_threadsafe(asyncio.async,
-                                        lambda: self._loop.stop())
+        self._loop.call_soon_threadsafe(lambda: self.stop())
 
     def _setup_signals(self, signals):
         self._signals = list(signals)

neovim/msgpack_rpc/event_loop/uv.py

@@ -12,7 +12,7 @@ class UvEventLoop(BaseEventLoop):
 
     def _init(self):
         self._loop = pyuv.Loop()
-        self._async = pyuv.Async(self._loop, lambda h: self._on_interrupt)
+        self._async = pyuv.Async(self._loop, lambda h: self.stop())
         self._connection_error = None
         self._error_stream = None
 

test/test_concurrency.py

@@ -2,7 +2,7 @@
 from random import random
 from nose.tools import with_setup, eq_ as eq
 from common import vim, cleanup
-from threading import Thread
+from threading import Thread, Timer
 
 
 @with_setup(setup=cleanup)
@@ -22,3 +22,12 @@ def produce(i):
         custom_messages.append(vim.session.next_message())
 
     eq(len(custom_messages), 50)
+
+
+@with_setup(setup=cleanup)
+def test_interrupt_from_another_thread():
+    timer = Timer(0.5, lambda: vim.session.post('timeout'))
+    timer.start()
+    msg = vim.session.next_message()
+    eq(msg[0], 'notification')
+    eq(msg[1], 'timeout')