-
Couldn't load subscription status.
- Fork 1.1k
[Streams] Fix null exceptions being propagated on downstream completion #7497
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Streams] Fix null exceptions being propagated on downstream completion #7497
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Self-review
| // Some stages might propagate null exceptions due to improper Task continuation handling | ||
| // (see https://github.com/akkadotnet/Akka.Persistence.Sql/issues/498) | ||
| // This is a stop gap solution to make sure that Akka.Streams doesn't behave improperly | ||
| // until we can fix all of those |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Document the reason in the code for future developers
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
| // Some stages might propagate null exceptions due to improper Task continuation handling | ||
| // (see https://github.com/akkadotnet/Akka.Persistence.Sql/issues/498) | ||
| // This is a stop gap solution to make sure that Akka.Streams doesn't behave improperly | ||
| // until we can fix all of those |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
|
Well the code looks good in spirit sans the compilation error :p |
|
It should be fixed now |
Fixes akkadotnet/Akka.Persistence.Sql#498
Changes
Replace null
Exceptionwith an empty exception to prevent stages from dying from improper task continuation handling.Checklist
For significant changes, please ensure that the following have been completed (delete if not relevant):