Class MergeDedupEventStream

  • All Implemented Interfaces:
    Closeable, AutoCloseable, Iterable<Event>, EventStream, RemotableOverRaw

    public class MergeDedupEventStream
    extends Object
    implements EventStream, RemotableOverRaw
    EventStream that is constructed with two source EventStream's ( for the same PV ) and then return's a merged-deduped stream of Events. The order of the streams in the constructor is significant as the first stream is the preferred stream in case of conflicts. For example, only the description from the first stream is used as the event description for this stream. Similarly, if both streams contain an event with the same timestamp, the event from the first stream ( along with all metainfo ) is used.