averello/vim-lsp-mirror
1
0
Fork 0
mirror of https://github.com/prabirshrestha/vim-lsp.git synced 2025-12-14 20:35:59 +01:00
Code Issues Packages Projects Releases Wiki Activity

use callbag share for stream and avoid directly using s:Stream (#996)

Browse Source 
Returns a shared version of callbag when calling lsp#stream so that there is a refcount to avoid accidental unsubscriptions and new subscribers will auto subscribe.
This commit is contained in:
Prabir Shrestha
2020-12-31 22:14:27 -08:00
committed by GitHub
parent ea78f5c6c3
commit b4f710f143
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
autoload/lsp.vim
View File

@@ -789,7 +789,7 @@ function! s:on_notification(server_name, id, data, event) abort
if has_key(a:data, 'request')
let l:stream_data['request'] = a:data['request']
endif
call s:Stream(1, l:stream_data) " notify stream before callbacks
call lsp#stream(1, l:stream_data) " notify stream before callbacks
if lsp#client#is_server_instantiated_notification(a:data)
if has_key(l:response, 'method')
@@ -816,7 +816,7 @@ function! s:on_request(server_name, id, request) abort
call lsp#log_verbose('<---', 's:on_request', a:id, a:request)
let l:stream_data = { 'server': a:server_name, 'request': a:request }
call s:Stream(1, l:stream_data) " notify stream before callbacks
call lsp#stream(1, l:stream_data) " notify stream before callbacks
if a:request['method'] ==# 'workspace/applyEdit'
call lsp#utils#workspace_edit#apply_workspace_edit(a:request['params']['edit'])
@@ -985,7 +985,7 @@ endfunction
" call lsp#stream(1, { 'command': 'DocumentFormat' })
function! lsp#stream(...) abort
if a:0 == 0
return s:Stream
return lsp#callbag#share(s:Stream)
else
call s:Stream(a:1, a:2)
endif
@@ -1171,7 +1171,7 @@ endfunction
function! lsp#_new_command() abort
let s:last_command_id += 1
call s:Stream(1, { 'command': 1 })
call lsp#stream(1, { 'command': 1 })
return s:last_command_id
endfunction