class DataStream extends Object implements ArchiveDataStream
StreamedArchiveRequester
benutzt.Modifier and Type | Field and Description |
---|---|
private ArchiveDataSpecification |
_archiveDataSpecification |
private static Debug |
_debug
DebugLogger für Debug-Ausgaben
|
private int |
_indexOfStream
Stream von dem die Daten geholt werden.
|
private Query |
_query
Dies ist die Anfrage, zu der dieser Stream gehört.
|
private StreamDemultiplexer |
_streamDemultiplexer |
Constructor and Description |
---|
DataStream(int indexOfStream,
StreamDemultiplexer streamDemultiplexer,
ArchiveDataSpecification archiveDataSpecification,
Query query)
Objekt, dass einen Stream repräsentiert.
|
Modifier and Type | Method and Description |
---|---|
void |
abort()
Diese Methode wird aufgerufen, falls keine Datensätze mehr benötigt werden.
|
ArchiveDataSpecification |
getDataSpecification()
Bestimmt die Archivdatenspezifikation, die zu diesem Ergebnisdatenstrom geführt hat.
|
ArchiveData |
take()
Diese Methode stellt einen archivierten Datensatz zur Verfügung.
|
private final StreamDemultiplexer _streamDemultiplexer
private final int _indexOfStream
private final Query _query
private final ArchiveDataSpecification _archiveDataSpecification
private static final Debug _debug
public DataStream(int indexOfStream, StreamDemultiplexer streamDemultiplexer, ArchiveDataSpecification archiveDataSpecification, Query query)
indexOfStream
- Index des StreamsstreamDemultiplexer
- Objekt über das Datensätze angefordert werden könnenarchiveDataSpecification
- Siehe Klassenbeschreibungquery
- Archivanfrage, die zu diesem Objekt gehörtpublic ArchiveDataSpecification getDataSpecification()
ArchiveDataStream
getDataSpecification
in interface ArchiveDataStream
public ArchiveData take() throws ClosedChannelException, InterruptedException, ProtocolException
take
in interface ArchiveDataStream
ClosedChannelException
- Die Verbindung zum DaV wurde unterbrochenInterruptedException
- Der Thread, der sich um die Verwaltung des Datensatzempfangs kümmert wurde mit
Interrupt
abgebrochenProtocolException
- Ein Datensatz wurde entweder doppelt empfangen oder fehltpublic void abort()
abort
in interface ArchiveDataStream