1
1
mirror of https://github.com/qvacua/vimr.git synced 2024-12-25 06:43:24 +03:00

Complete delegate stream

This commit is contained in:
Tae Won Ha 2017-12-17 23:44:34 +01:00
parent 771a2fc2e9
commit 5038cf21bb
No known key found for this signature in database
GPG Key ID: E40743465B5B8B44
2 changed files with 3 additions and 0 deletions

View File

@ -198,6 +198,7 @@ extension NvimView {
public func quitNeoVimWithoutSaving() {
self.nvim.command(command: "qa!", expectsReturnValue: false)
self.eventsSubject.onNext(.neoVimStopped)
self.eventsSubject.onCompleted()
self.waitForNeoVimToQuit()
}

View File

@ -186,6 +186,7 @@ extension NvimView {
gui.async {
self.waitForNeoVimToQuit()
self.eventsSubject.onNext(.neoVimStopped)
self.eventsSubject.onCompleted()
}
}
@ -218,6 +219,7 @@ extension NvimView {
}
self.eventsSubject.onNext(.ipcBecameInvalid(reason))
self.eventsSubject.onCompleted()
self.bridgeLogger.error("Force-closing due to IPC error.")
self.nvim.disconnect()