Skip to content

Commit

Permalink
Merge pull request #304 from mhinz/close
Browse files Browse the repository at this point in the history
MsgpackStream: fix typos
  • Loading branch information
bfredl authored Mar 1, 2018
2 parents 9f30572 + 0a679ab commit df3746f
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions neovim/msgpack_rpc/msgpack_stream.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,12 +27,12 @@ def __init__(self, event_loop):

def threadsafe_call(self, fn):
"""Wrapper around `BaseEventLoop.threadsafe_call`."""
self.loop .threadsafe_call(fn)
self.loop.threadsafe_call(fn)

def send(self, msg):
"""Queue `msg` for sending to Nvim."""
debug('sent %s', msg)
self.loop .send(self._packer.pack(msg))
self.loop.send(self._packer.pack(msg))

def run(self, message_cb):
"""Run the event loop to receive messages from Nvim.
Expand All @@ -41,16 +41,16 @@ def run(self, message_cb):
a message has been successfully parsed from the input stream.
"""
self._message_cb = message_cb
self.loop .run(self._on_data)
self.loop.run(self._on_data)
self._message_cb = None

def stop(self):
"""Stop the event loop."""
self.loop .stop()
self.loop.stop()

def close(self):
"""Close the event loop."""
self._event_loop.close()
self.loop.close()

def _on_data(self, data):
self._unpacker.feed(data)
Expand Down

0 comments on commit df3746f

Please sign in to comment.