Package org.epics.archiverappliance.retrieval.workers

Class CurrentThreadWorkerEventStream

java.lang.Object

org.epics.archiverappliance.retrieval.workers.CurrentThreadWorkerEventStream

All Implemented Interfaces:

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

public class CurrentThreadWorkerEventStream
extends Object
implements EventStream, RemotableOverRaw

Expands the results from a Reader using the current thread. This is the default strategy for most retrievals; especially if the data sizes are large; here, we leverage streaming to minimize memory consumption. We only support one iterator for this stream.

Author:

mshankar

Constructor Summary

Constructors

Constructor	Description
CurrentThreadWorkerEventStream(String pvName, List<Callable<EventStream>> streams)

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

CurrentThreadWorkerEventStream

public CurrentThreadWorkerEventStream(String pvName,
 List<Callable<EventStream>> streams)

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

iterator

public Iterator<Event> iterator()

Specified by:

iterator in interface Iterable<Event>

getDescription

public RemotableEventStreamDesc getDescription()

Specified by:

getDescription in interface EventStream

Specified by:

getDescription in interface RemotableOverRaw