public class CollectingReceiver
extends java.lang.Object
Speichert vom Datenverteiler empfangene Datensätze zur späteren Auslieferung an einen Receiver der Applikation.
Modifier and Type | Field and Description |
---|---|
private int |
_collectedSize
Gesamtgröße der auszuliefernden Datensätze.
|
private ClientReceiverInterface |
_receiver
Receiver der Applikation, an den die gespeicherten Datensätze ausgeliefert werden sollen.
|
private int |
_referenceCount |
private java.util.ArrayList<ResultData> |
_results
Liste mit den auszuliefernden Datensätzen
|
Constructor and Description |
---|
CollectingReceiver(ClientReceiverInterface receiver)
Erzeugt ein neues Objekt für den angegebenen Receiver
|
Modifier and Type | Method and Description |
---|---|
boolean |
decrementReferenceCount()
Verringert den Referenzzähler um eins.
|
int |
deliver()
Liefert die gespeicherten Datensätze an den Receiver der Applikation aus.
|
void |
incrementReferenceCount()
Erhöht den Referenzzähler um eins.
|
boolean |
storeForDelivery(ResultData result,
int size)
Speichert einen Datensatz zur späteren Auslieferung an den zugeordneten Receiver der Applikation.
|
private final java.util.ArrayList<ResultData> _results
Liste mit den auszuliefernden Datensätzen
private final ClientReceiverInterface _receiver
Receiver der Applikation, an den die gespeicherten Datensätze ausgeliefert werden sollen.
private int _collectedSize
Gesamtgröße der auszuliefernden Datensätze.
private int _referenceCount
public CollectingReceiver(ClientReceiverInterface receiver)
Erzeugt ein neues Objekt für den angegebenen Receiver
public boolean storeForDelivery(ResultData result, int size)
Speichert einen Datensatz zur späteren Auslieferung an den zugeordneten Receiver der Applikation.
result
- Zu speichernder Datensatz.size
- Größe des zu speichernden Datensatzes.true
, wenn kein noch nicht ausgelieferter Datensatz gespeichert war; false
sonst.public int deliver()
Liefert die gespeicherten Datensätze an den Receiver der Applikation aus.
public void incrementReferenceCount()
Erhöht den Referenzzähler um eins.
public boolean decrementReferenceCount()
Verringert den Referenzzähler um eins.
true
, wenn der Referenzzähler den Wert 0 erreicht hat.