foldcc/UniTask
1
0
Fork 0
mirror of https://github.com/Cysharp/UniTask.git synced 2026-05-22 07:40:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Continue to subscribe if an exception is raised when calling onNext

Browse Source
This commit is contained in:
Mayuki Sawatari
2020-08-24 14:44:15 +09:00
parent 7718d345c8
commit f1813a7c94
1 changed files with 32 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
src/UniTask/Assets/Plugins/UniTask/Runtime/Linq/Subscribe.cs
View File

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