Lean
$LEAN_TAG$
|
Provides an implementation of ISubscriptionEnumeratorFactory to handle live custom data. More...
Public Member Functions | |
LiveCustomDataSubscriptionEnumeratorFactory (ITimeProvider timeProvider, IObjectStore objectStore, Func< DateTime, DateTime > dateAdjustment=null, TimeSpan? minimumIntervalCheck=null) | |
Initializes a new instance of the LiveCustomDataSubscriptionEnumeratorFactory class More... | |
IEnumerator< BaseData > | CreateEnumerator (SubscriptionRequest request, IDataProvider dataProvider) |
Creates an enumerator to read the specified request. More... | |
Protected Member Functions | |
virtual ISubscriptionDataSourceReader | GetSubscriptionDataSourceReader (SubscriptionDataSource source, IDataCacheProvider dataCacheProvider, SubscriptionDataConfig config, DateTime date, BaseData baseDataInstance, IDataProvider dataProvider) |
Gets the ISubscriptionDataSourceReader for the specified source More... | |
Provides an implementation of ISubscriptionEnumeratorFactory to handle live custom data.
Definition at line 30 of file LiveCustomDataSubscriptionEnumeratorFactory.cs.
QuantConnect.Lean.Engine.DataFeeds.Enumerators.Factories.LiveCustomDataSubscriptionEnumeratorFactory.LiveCustomDataSubscriptionEnumeratorFactory | ( | ITimeProvider | timeProvider, |
IObjectStore | objectStore, | ||
Func< DateTime, DateTime > | dateAdjustment = null , |
||
TimeSpan? | minimumIntervalCheck = null |
||
) |
Initializes a new instance of the LiveCustomDataSubscriptionEnumeratorFactory class
timeProvider | Time provider from data feed |
objectStore | The object store to use |
dateAdjustment | Func that allows adjusting the datetime to use |
minimumIntervalCheck | Allows specifying the minimum interval between each enumerator refresh and data check, default is 30 minutes |
Definition at line 44 of file LiveCustomDataSubscriptionEnumeratorFactory.cs.
IEnumerator<BaseData> QuantConnect.Lean.Engine.DataFeeds.Enumerators.Factories.LiveCustomDataSubscriptionEnumeratorFactory.CreateEnumerator | ( | SubscriptionRequest | request, |
IDataProvider | dataProvider | ||
) |
Creates an enumerator to read the specified request.
request | The subscription request to be read |
dataProvider | Provider used to get data when it is not present on disk |
Implements QuantConnect.Data.ISubscriptionEnumeratorFactory.
Definition at line 59 of file LiveCustomDataSubscriptionEnumeratorFactory.cs.
|
protectedvirtual |
Gets the ISubscriptionDataSourceReader for the specified source
Definition at line 187 of file LiveCustomDataSubscriptionEnumeratorFactory.cs.