General Operators
References of operators for general purpose.
completeOnTimeout()
Observable is completed when there is no observation for a certain period of time.
Note
timeout() finishes the observable as error, not as complete.
sort()
A more generic variation of sortEvents().
filterBySubId()
Only packets with subId matching the given value are passed through, all others will be eliminated. Available for EventPacket, EosePacket, ClosedPacket, and CountPacket Observables.