private static class ArchiveStreamCombiner.CombinedStream extends Object implements ArchiveDataStream
Modifier and Type | Field and Description |
---|---|
private int |
_currentIndex |
private ArchiveDataSpecification |
_spec |
private ArchiveDataStream[] |
_streamsToCombine |
private boolean |
hasSendData |
Constructor and Description |
---|
ArchiveStreamCombiner.CombinedStream(ArchiveDataStream[] streamsToCombine,
ArchiveDataSpecification spec) |
Modifier and Type | Method and Description |
---|---|
void |
abort()
Bricht die Übertragung von Datensätzen für diesen Ergebnisdatenstrom ab.
|
private ArchiveDataStream |
current() |
ArchiveDataSpecification |
getDataSpecification()
Bestimmt die Archivdatenspezifikation, die zu diesem Ergebnisdatenstrom geführt hat.
|
ArchiveData |
take()
Entfernt einen Datensatz vom Ergebnisdatenstrom und gibt ihn zurück.
|
private ArchiveDataStream[] _streamsToCombine
private ArchiveDataSpecification _spec
private int _currentIndex
private boolean hasSendData
public ArchiveStreamCombiner.CombinedStream(ArchiveDataStream[] streamsToCombine, ArchiveDataSpecification spec)
public ArchiveDataSpecification getDataSpecification()
ArchiveDataStream
getDataSpecification
in interface ArchiveDataStream
private ArchiveDataStream current()
public ArchiveData take() throws InterruptedException, IOException, IllegalStateException
ArchiveDataStream
null
signalisiert werden.take
in interface ArchiveDataStream
null
, wenn alle Datensätze dieses Ergeebnisdatenstroms
abgefragt wurden.InterruptedException
- Falls der aufrufende Thread unterbrochen wurde, während auf den nächsten Datensatz
gewartet wurde.IOException
- Falls Probleme in der Kommunikation mit dem Archivsystem aufgetreten sind und noch
nicht alle Datensätze übertragen wurden.IllegalStateException
- Falls der Ergebnisdatenstrom mit der Methode ArchiveDataStream.abort()
abgebrochen wurde.public void abort()
ArchiveDataStream
ArchiveDataStream.take()
werden mit einer entsprechenden Exception quittiert.abort
in interface ArchiveDataStream