Fix potential unobserved exception in InputHandler.cs

OmniSharp · Aug 12, 2021 · e70890d · e70890d
1 parent 5281160
commit e70890d
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/src/JsonRpc/InputHandler.cs b/src/JsonRpc/InputHandler.cs
@@ -110,9 +110,16 @@ IScheduler scheduler
         public void Start()
         {
             _disposable.Add(
-                Observable.FromAsync(() => ProcessInputStream(_stopProcessing.Token))
-                          .Do(_ => { }, e => _logger.LogCritical(e, "unhandled exception"))
-                          .Subscribe(_inputActive)
+                Observable.FromAsync(async () => {
+                    try
+                    {
+                        await ProcessInputStream(_stopProcessing.Token).ConfigureAwait(false);
+                    }
+                    catch (Exception e)
+                    {
+                        _logger.LogCritical(e, "unhandled exception");
+                    }
+                }).Subscribe(_inputActive)
             );
             _disposable.Add(
                 _inputQueue