Package org.epics.archiverappliance.common.mergededup

Class MergeDedupWithCallablesEventStream

java.lang.Object

org.epics.archiverappliance.common.mergededup.MergeDedupWithCallablesEventStream

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Event>, RemotableOverRaw, EventStream

public class MergeDedupWithCallablesEventStream
extends Object
implements EventStream, RemotableOverRaw

This is almost idential to the MergeDedupEventStream; expect it takes as its first argument a list of EventStream callables which it then merges with the second EventStream

Author:

mshankar

Constructor Summary

Constructors

Constructor	Description
MergeDedupWithCallablesEventStream(List<Callable<EventStream>> clbs1, List<Callable<EventStream>> clbs2)
MergeDedupWithCallablesEventStream(List<Callable<EventStream>> clbs, EventStream stream2, PostProcessor postProcessor)

Method Summary

Modifier and Type	Method	Description
void	close()
RemotableEventStreamDesc	getDescription()
Iterator<Event>	iterator()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

MergeDedupWithCallablesEventStream

public MergeDedupWithCallablesEventStream(List<Callable<EventStream>> clbs1,
 List<Callable<EventStream>> clbs2)

MergeDedupWithCallablesEventStream

public MergeDedupWithCallablesEventStream(List<Callable<EventStream>> clbs,
 EventStream stream2,
 PostProcessor postProcessor)

Method Details

iterator

public Iterator<Event> iterator()

Specified by:

iterator in interface Iterable<Event>

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getDescription

public RemotableEventStreamDesc getDescription()

Specified by:

getDescription in interface EventStream

Specified by:

getDescription in interface RemotableOverRaw