We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 89a97d1 commit de1591eCopy full SHA for de1591e
src/JsonRpc/InputHandler.cs
@@ -110,9 +110,16 @@ IScheduler scheduler
110
public void Start()
111
{
112
_disposable.Add(
113
- Observable.FromAsync(() => ProcessInputStream(_stopProcessing.Token))
114
- .Do(_ => { }, e => _logger.LogCritical(e, "unhandled exception"))
115
- .Subscribe(_inputActive)
+ Observable.FromAsync(async () => {
+ try
+ {
116
+ await ProcessInputStream(_stopProcessing.Token).ConfigureAwait(false);
117
+ }
118
+ catch (Exception e)
119
120
+ _logger.LogCritical(e, "unhandled exception");
121
122
+ }).Subscribe(_inputActive)
123
);
124
125
_inputQueue
0 commit comments