You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
In trying to use WriteStreamSubscriber I found my items were not being delivered. On debug they were being skipped in onNext with "if (!done.get()) return" It seems this is the wrong way around and we want to skip and return immediately if done is true. I will add a pull request.
The text was updated successfully, but these errors were encountered:
syndic8-stephen
added a commit
to syndic8-stephen/smallrye-reactive-utils
that referenced
this issue
Jul 13, 2020
In trying to use WriteStreamSubscriber I found my items were not being delivered. On debug they were being skipped in onNext with "if (!done.get()) return" It seems this is the wrong way around and we want to skip and return immediately if done is true. I will add a pull request.
The text was updated successfully, but these errors were encountered: