LiveSubscriptionEnumerator

QuantConnect.Lean.Engine.DataFeeds.Enumerators.LiveSubscriptionEnumerator

LiveSubscriptionEnumerator(
    data_config: SubscriptionDataConfig,
    data_queue_handler: IDataQueueHandler,
    handler: Callable[[Object, EventArgs], Any],
    is_expired: Callable[[SubscriptionDataConfig], bool],
)

Bases: Object, IEnumerator[BaseData]

Enumerator that will subscribe through the provided data queue handler and refresh the subscription if any mapping occurs

Creates a new instance

current

current: BaseData

The current data object instance

dispose

dispose() -> None

Disposes of the used enumerators

move_next

move_next() -> bool

Advances the enumerator to the next element.

reset

reset() -> None

Reset the IEnumeration