-
Notifications
You must be signed in to change notification settings - Fork 7.6k
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
Operator retry test fix attempt #2332
Conversation
@@ -227,9 +227,9 @@ public void awaitTerminalEvent() { | |||
* @throws RuntimeException | |||
* if the Subscriber is interrupted before the Observable is able to complete | |||
*/ | |||
public void awaitTerminalEvent(long timeout, TimeUnit unit) { | |||
public boolean awaitTerminalEvent(long timeout, TimeUnit unit) { |
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.
This is a breaking change.
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.
Any suggestion how I can sneak out the await's result?
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.
Throw TimeoutException
? It's a bit minor breaking change. @benjchristensen Is it fine?
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.
Or add a new method?
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.
I've changed it back and made it throw a RTE with TimeoutException as cause.
Maybe the error function was not emitting events properly.