Uses of Class
com.devexperts.qd.ng.RecordSource

Packages that use RecordSource

Package	Description
com.devexperts.qd	This package contains basic interfaces and other API elements of QD system which shall be sufficient for the client application programmer.
com.devexperts.qd.ng	This package contains next-generation interfaces for data and subscription exchange based on RecordCursor class.
com.devexperts.qd.qtp	This package contains interfaces with default implementations required to create and operate a connection using QTP.
com.devexperts.qd.util	This package contains utility classes which are used by QD, but which do not depend on QD and which do not constitute any separate module or subsystem.

Uses of RecordSource in com.devexperts.qd

Methods in com.devexperts.qd with parameters of type RecordSource

Modifier and Type	Method and Description
void	QDAgent.addSubscription(RecordSource source) Adds specified subscription to this agent's data interest.
int	QDAgent.addSubscriptionPart(RecordSource source, int notify) Adds part of a specified subscription to this agent's data interest.
boolean	QDCollector.examineDataBySubscription(RecordSink sink, RecordSource sub) Examines all stored data for a given subscription via specified sink.
void	QDDistributor.process(RecordSource source) Processes all data from specified record source.
void	QDCollector.remove(RecordSource source) Removes the corresponding records from the underlying storage.
void	QDAgent.removeSubscription(RecordSource source) Removes specified subscription from this agent's data interest.
int	QDAgent.removeSubscriptionPart(RecordSource source, int notify) Removes part of specified subscription from this agent's data interest.
void	QDAgent.setSubscription(RecordSource source) Sets specified subscription to be this agent's data interest.
int	QDAgent.setSubscriptionPart(RecordSource source, int notify) Sets part of specified subscription to be this agent's data interest.

Uses of RecordSource in com.devexperts.qd.ng

Subclasses of RecordSource in com.devexperts.qd.ng

Modifier and Type	Class and Description
class	RecordBuffer Buffers int and obj values of data records.

Fields in com.devexperts.qd.ng declared as RecordSource

Modifier and Type	Field and Description
static RecordSource	RecordSource.VOID An empty record source.

Methods in com.devexperts.qd.ng that return RecordSource

Modifier and Type	Method and Description
abstract RecordSource	RecordSource.newSource() Returns new RecordSource that reads this record source from its current position to its limit.
RecordSource	RecordBuffer.newSource() Returns new RecordSource that reads this record buffer from current position to its current limit with the same mode.
abstract RecordSource	RecordSource.newSource(long start, long end) Returns new RecordSource that reads this record source from the specified start position to the specified end position.
RecordSource	RecordBuffer.newSource(long start, long end) Returns new RecordSource that reads this record buffer from the specified start position to the specified end position.

Methods in com.devexperts.qd.ng with parameters of type RecordSource

Modifier and Type	Method and Description
void	RecordBuffer.addAll(RecordSource source) Deprecated. Use RecordBuffer.process(RecordSource).
void	RecordBuffer.addAll(RecordSource source, SubscriptionFilter filter) Deprecated. Use RecordBuffer.process(RecordSource, SubscriptionFilter).
void	RecordConsumer.process(RecordSource source) Processes all records from specified record source.
void	RecordBuffer.process(RecordSource source) Adds all records from the specified source to this buffer.
void	RecordBuffer.process(RecordSource source, SubscriptionFilter filter) Adds all records that match a given filter from the specified source to this buffer.

Uses of RecordSource in com.devexperts.qd.qtp

Methods in com.devexperts.qd.qtp with parameters of type RecordSource

Modifier and Type	Method and Description
void	MessageConsumerAdapter.processRecordSource(RecordSource source, MessageType message) This method calls either MessageConsumerAdapter.processData(DataIterator, MessageType) or MessageConsumerAdapter.processSubscription(SubscriptionIterator, MessageType) depending on message.
boolean	AgentChannels.processSubscription(RecordSource sub, QDContract contract, boolean isSubscriptionAdd) Processes subscription.

Uses of RecordSource in com.devexperts.qd.util

Methods in com.devexperts.qd.util that return RecordSource

Modifier and Type	Method and Description
static RecordSource	LegacyAdapter.of(SubscriptionIterator iterator)

Methods in com.devexperts.qd.util with parameters of type RecordSource

Modifier and Type	Method and Description
protected abstract void	RecordProcessor.process(RecordSource source) Method for processing incoming records.
protected void	DataProcessor.process(RecordSource source) Deprecated.
protected abstract void	SubscriptionProcessor.processAddedSubscription(RecordSource source) Method for processing incoming added subscription from QD.
protected abstract void	DataProcessor.processData(RecordSource source) Deprecated. Method for processing incoming data from QD.
protected abstract void	SubscriptionProcessor.processRemovedSubscription(RecordSource source) Method for processing incoming removed subscription from QD.
static void	LegacyAdapter.release(SubscriptionIterator iterator, RecordSource source)