Fixes the .BufferedDebounce to actualy buffer

this was processing observable windows as they came in instead of waiting for them the close.
ionide · Oct 11, 2022 · ea846b5 · ea846b5
1 parent 0a184c5
commit ea846b5
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/FsAutoComplete/LspServers/AdaptiveFSharpLspServer.fs b/src/FsAutoComplete/LspServers/AdaptiveFSharpLspServer.fs
@@ -440,8 +440,8 @@ type AdaptiveFSharpLspServer(workspaceLoader: IWorkspaceLoader, lspClient: FShar
   do
     disposables.Add(
       (notifications.Publish :> IObservable<_>)
-        // .BufferedDebounce(TimeSpan.FromMilliseconds(200.))
-        // .SelectMany(fun l -> l.Distinct())
+        .BufferedDebounce(TimeSpan.FromMilliseconds(200.))
+        .SelectMany(fun l -> l.Distinct())
         .Subscribe(fun e -> handleCommandEvents e)
     )
 

diff --git a/src/FsAutoComplete/LspServers/Common.fs b/src/FsAutoComplete/LspServers/Common.fs
@@ -188,7 +188,9 @@ module ObservableExtensions =
 
     /// Fires an event only after the specified interval has passed in which no other pending event has fired. Buffers all events leading up to that emit.
     member x.BufferedDebounce(ts: TimeSpan) =
-      x.Publish(fun shared -> shared.Window(shared.Throttle(ts)))
+      x
+        .Publish(fun shared -> shared.Window(shared.Throttle(ts)))
+        .SelectMany(fun l -> l.ToList())
 
 module Helpers =
   let notImplemented<'t> = async.Return LspResult.notImplemented<'t>