IDataQueueHandler

QuantConnect.Interfaces.IDataQueueHandler

Bases: IDisposable

Task requestor interface with cloud system

is_connected

is_connected: bool

Returns whether the data provider is connected

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]

Subscribe to the specified configuration

Parameters:

Name	Type	Description	Default
`data_config`	`SubscriptionDataConfig`	defines the parameters to subscribe to a data feed	required
`new_data_available_handler`	`Callable[[Object, EventArgs], Any]`	handler to be fired on new data available	required

Returns:

Type	Description
`IEnumerator[BaseData]`	The new enumerator for this subscription request.

unsubscribe

unsubscribe(data_config: SubscriptionDataConfig) -> None

Removes the specified configuration

Parameters:

Name	Type	Description	Default
`data_config`	`SubscriptionDataConfig`	Subscription config to be removed	required