Lean  $LEAN_TAG$
QuantConnect.Lean.Engine.DataFeeds.SubscriptionUtils Class Reference

Utilities related to data Subscription More...

Static Public Member Functions

static Subscription Create (SubscriptionRequest request, IEnumerator< BaseData > enumerator)
 Creates a new Subscription which will directly consume the provided enumerator More...
 
static Subscription CreateAndScheduleWorker (SubscriptionRequest request, IEnumerator< BaseData > enumerator, IFactorFileProvider factorFileProvider, bool enablePriceScale)
 Setups a new Subscription which will consume a blocking EnqueueableEnumerator<T> that will be feed by a worker task More...
 

Detailed Description

Utilities related to data Subscription

Definition at line 33 of file SubscriptionUtils.cs.

Member Function Documentation

◆ Create()

static Subscription QuantConnect.Lean.Engine.DataFeeds.SubscriptionUtils.Create ( SubscriptionRequest  request,
IEnumerator< BaseData enumerator 
)
static

Creates a new Subscription which will directly consume the provided enumerator

Parameters
requestThe subscription data request
enumeratorThe data enumerator stack
Returns
A new subscription instance ready to consume

Definition at line 41 of file SubscriptionUtils.cs.

Here is the caller graph for this function:

◆ CreateAndScheduleWorker()

static Subscription QuantConnect.Lean.Engine.DataFeeds.SubscriptionUtils.CreateAndScheduleWorker ( SubscriptionRequest  request,
IEnumerator< BaseData enumerator,
IFactorFileProvider  factorFileProvider,
bool  enablePriceScale 
)
static

Setups a new Subscription which will consume a blocking EnqueueableEnumerator<T> that will be feed by a worker task

Parameters
requestThe subscription data request
enumeratorThe data enumerator stack
factorFileProviderThe factor file provider
enablePriceScaleEnables price factoring
Returns
A new subscription instance ready to consume

Definition at line 70 of file SubscriptionUtils.cs.

Here is the call graph for this function:
Here is the caller graph for this function:

The documentation for this class was generated from the following file: