Skip to content

Conversation

Kn1kt
Copy link

@Kn1kt Kn1kt commented Nov 13, 2022

Continuation of Update testSuccessfulRetry and code to make it pass. #150

First commit

  1. When RetryWhen changes upstream to Sink, the subscription to the previous upstream must be canceled in order not to receive unnecessary events.
  2. You also need to re-request from the new upstream demand, which was not received from the previous upstream.

Second commit

Adds tests for both cases described above

Third commit

Added explicit cancellation of subscriptions in the cancel() method call. Because deinit on Sink can be called after a while, forcing the publisher to work.
This causes a lot of problems when using RetryWhen in cells of collections or tables, where the cancel() method can be called very often and the deinit call on Sink can occur after a few tens of seconds.

@Kn1kt Kn1kt mentioned this pull request Nov 13, 2022
@Kn1kt Kn1kt closed this by deleting the head repository Aug 25, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant