com.devexperts.qd

Interface SubscriptionVisitor

All Known Subinterfaces:

RecordSink

All Known Implementing Classes:

AbstractQTPComposer, AbstractRecordSink, BinaryQTPComposer, ByteArrayComposer, DataSink, OutputStreamComposer, RecordBuffer, SubscriptionBuffer

public interface SubscriptionVisitor

The SubscriptionVisitor provides serial access to subscription. It follows the same pattern as DataVisitor except it does not go through data fields.

NOTE: This interface is formally unrelated to its data analogue to enforce strict type safety; also their state diagrams are not compatible.

Legacy interface

FUTURE DEPRECATION NOTE: New code shall not implement this interface due to its complexity and inherent slowness. Use AbstractRecordSink or RecordBuffer as a high-performance implementation of it. New code is also discouraged from using this interface unless it is need for interoperability with legacy code. Various legacy APIs will be gradually migrated to NG interfaces and classes.

Field Summary

Fields

Modifier and Type	Field and Description
static SubscriptionVisitor	VOID

Method Summary

Modifier and Type	Method and Description
boolean	hasCapacity() Returns whether visitor has capacity to efficiently visit next record.
void	visitRecord(DataRecord record, int cipher, String symbol, long time) Visits next record.

Field Detail

VOID

static final SubscriptionVisitor VOID

Method Detail

hasCapacity

boolean hasCapacity()

Returns whether visitor has capacity to efficiently visit next record. This method may be used to advise subscription provider that it is desirable to stop current string of visiting and to keep remaining subscription. However, at present, subscription provider is not obliged to adhere to this method contract.

NOTE: subscription visitor must process all subscription that is passed to it via visitXXX calls no matter whether it has capacity to do it efficiently.

visitRecord

void visitRecord(DataRecord record,
                 int cipher,
                 String symbol,
                 long time)

Visits next record.