Package gda.device.scannable

Class PositionStreamIndexer<T>

java.lang.Object

gda.device.scannable.PositionStreamIndexer<T>

Type Parameters:

T -

All Implemented Interfaces:

PositionCallableProvider<T>

public class PositionStreamIndexer<T>
extends Object
implements PositionCallableProvider<T>

Used as a component in PositionCallableProviders that implement PositionInputStreams an indexer can be deferred to to very easily implement PositionCallableProvider.getPositionCallable().

Constructor Summary

Constructors

Constructor	Description
PositionStreamIndexer(PositionInputStream<T> stream)
PositionStreamIndexer(PositionInputStream<T> stream, int maxElementsToReadInOneGo)

Method Summary

Modifier and Type	Method	Description
T	get(int index)	Can only be called once for each index
Callable<T>	getNamedPositionCallable(String name, int threadPoolSize)
Callable<T>	getPositionCallable()

Methods inherited from class java.lang.Object

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

Constructor Details

PositionStreamIndexer

public PositionStreamIndexer(PositionInputStream<T> stream)

PositionStreamIndexer

public PositionStreamIndexer(PositionInputStream<T> stream,
 int maxElementsToReadInOneGo)

Method Details

get

public T get(int index)
      throws NoSuchElementException,
InterruptedException,
DeviceException

Can only be called once for each index

Throws:

NoSuchElementException

InterruptedException

DeviceException

getPositionCallable

public Callable<T> getPositionCallable()
                                throws DeviceException

Specified by:

getPositionCallable in interface PositionCallableProvider<T>

Throws:

DeviceException

getNamedPositionCallable

public Callable<T> getNamedPositionCallable(String name,
 int threadPoolSize)