Package deltix.qsrv.hf.tickdb.pub.query
Interface StreamSubscriptionController
-
- All Known Subinterfaces:
InstrumentMessageSource
,SubscriptionController
,TickCursor
- All Known Implementing Classes:
InstrumentMessageSourceAdapter
,LimitedInstrumentMessageSource
,SubscriptionManagerWrapper
,TickCursorAdapter
,TickCursorClientAeron
public interface StreamSubscriptionController
Controls the set of original streams from which information is being selected. Methods have no return value, because they can act asynchronously. The implementor of this interface is not required to remember the subscription; therefore, there are no methods provided to query the current state (such as "hasStream", "getStreams", etc.). The user of this interface can independently track current subscription, if so desired.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
addStream(TickStream... tickStreams)
Add streams to subscription.void
removeAllStreams()
Remove all streams from subscription.void
removeStream(TickStream... tickStreams)
Remove streams from subscription.
-
-
-
Method Detail
-
addStream
void addStream(TickStream... tickStreams)
Add streams to subscription. Current time and filter is used to query data from new sources.- Parameters:
tickStreams
- Streams to add.
-
removeAllStreams
void removeAllStreams()
Remove all streams from subscription.
-
removeStream
void removeStream(TickStream... tickStreams)
Remove streams from subscription.- Parameters:
tickStreams
- Streams to remove.
-
-