LiveDataQueue

QuantConnect.Lean.Engine.DataFeeds.Queues.LiveDataQueue

Bases: Object, IDataQueueHandler

Live Data Queue is the cut out implementation of how to bind a custom live data source

is_connected

is_connected: bool

Returns whether the data provider is connected

dispose

dispose() -> None

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

set_job

set_job(job: LiveNodePacket) -> None

Sets the job we're subscribing for

Parameters:

Name	Type	Description	Default
job	LiveNodePacket	Job we're subscribing for	required

subscribe

subscribe(
    data_config: SubscriptionDataConfig,
    new_data_available_handler: Callable[
        [Object, EventArgs], Any
    ],
) -> IEnumerator[BaseData]

Desktop/Local doesn't support live data from this handler

unsubscribe

unsubscribe(data_config: SubscriptionDataConfig) -> None

Desktop/Local doesn't support live data from this handler