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()
ArchiveDataStreamgetDataSpecification in interface ArchiveDataStreampublic ArchiveData take() throws ClosedChannelException, InterruptedException, ProtocolException
take in interface ArchiveDataStreamClosedChannelException - 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