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()
ArchiveDataStreamgetDataSpecification in interface ArchiveDataStreamprivate ArchiveDataStream current()
public ArchiveData take() throws InterruptedException, IOException, IllegalStateException
ArchiveDataStreamnull signalisiert werden.take in interface ArchiveDataStreamnull, 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()
ArchiveDataStreamArchiveDataStream.take() werden mit einer entsprechenden Exception quittiert.abort in interface ArchiveDataStream