|
@@ -50,6 +50,7 @@ namespace System.Reactive.Linq
|
|
catch (Exception ex)
|
|
catch (Exception ex)
|
|
{
|
|
{
|
|
await observer.OnErrorAsync(ex).ConfigureAwait(false);
|
|
await observer.OnErrorAsync(ex).ConfigureAwait(false);
|
|
|
|
+ return;
|
|
}
|
|
}
|
|
|
|
|
|
if (b)
|
|
if (b)
|
|
@@ -107,6 +108,7 @@ namespace System.Reactive.Linq
|
|
catch (Exception ex)
|
|
catch (Exception ex)
|
|
{
|
|
{
|
|
await observer.OnErrorAsync(ex).ConfigureAwait(false);
|
|
await observer.OnErrorAsync(ex).ConfigureAwait(false);
|
|
|
|
+ return;
|
|
}
|
|
}
|
|
|
|
|
|
if (b)
|
|
if (b)
|