Merge pull request #138 from Cysharp/hotfix/ContinueOnErrorCallingOnNext

Continue to subscribe if an exception is raised when calling onNext
master
Yoshifumi Kawai 2020-08-25 07:11:43 +09:00 committed by GitHub
commit 7eac5d8ba8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 32 additions and 4 deletions

View File

@ -195,7 +195,14 @@ namespace Cysharp.Threading.Tasks.Linq
{
while (await e.MoveNextAsync())
{
onNext(e.Current);
try
{
onNext(e.Current);
}
catch (Exception ex)
{
UniTaskScheduler.PublishUnobservedTaskException(ex);
}
}
onCompleted();
}
@ -227,7 +234,14 @@ namespace Cysharp.Threading.Tasks.Linq
{
while (await e.MoveNextAsync())
{
onNext(e.Current).Forget();
try
{
onNext(e.Current).Forget();
}
catch (Exception ex)
{
UniTaskScheduler.PublishUnobservedTaskException(ex);
}
}
onCompleted();
}
@ -259,7 +273,14 @@ namespace Cysharp.Threading.Tasks.Linq
{
while (await e.MoveNextAsync())
{
onNext(e.Current, cancellationToken).Forget();
try
{
onNext(e.Current, cancellationToken).Forget();
}
catch (Exception ex)
{
UniTaskScheduler.PublishUnobservedTaskException(ex);
}
}
onCompleted();
}
@ -291,7 +312,14 @@ namespace Cysharp.Threading.Tasks.Linq
{
while (await e.MoveNextAsync())
{
observer.OnNext(e.Current);
try
{
observer.OnNext(e.Current);
}
catch (Exception ex)
{
UniTaskScheduler.PublishUnobservedTaskException(ex);
}
}
observer.OnCompleted();
}