Github user sardell commented on the issue:
https://github.com/apache/metron/pull/1240
@tiborm In regard to the 'Initial' state check, I was able to do what you
suggested but only after switching from a BehaviorSubject to a Subject. I did
this because Subjects do not return the current value on Subscription. It only
triggers with the .next() call and returns the value you pass there. That was a
really great suggestion on your part and made me realize I was using the wrong
tool for the job.
I also made changes based on the rest of your feedback, but they were
straightforward and do not need further explanation here. Thanks for taking the
time to review my PR!
---
