Represents a stream reader capable of reading lines from disk More...

Inheritance diagram for QuantConnect.Lean.Engine.DataFeeds.Transport.LocalFileSubscriptionStreamReader:

Public Member Functions
	LocalFileSubscriptionStreamReader (IDataCacheProvider dataCacheProvider, string source, string entryName=null)
	Initializes a new instance of the LocalFileSubscriptionStreamReader class. More...

	LocalFileSubscriptionStreamReader (IDataCacheProvider dataCacheProvider, string source, long startingPosition)
	Initializes a new instance of the LocalFileSubscriptionStreamReader class. More...

	LocalFileSubscriptionStreamReader (ZipFile zipFile, string entryName=null)
	Initializes a new instance of the LocalFileSubscriptionStreamReader class. More...

string	ReadLine ()
	Gets the next line/batch of content from the stream More...

void	Dispose ()
	Disposes of the stream More...

Public Attributes
bool	ShouldBeRateLimited => false
	Gets whether or not this stream reader should be rate limited More...

Properties
StreamReader	StreamReader `[get]`
	Direct access to the StreamReader instance More...

IEnumerable< string >?	EntryFileNames `[get]`
	Returns the list of zip entries if local file stream reader is reading zip archive More...

SubscriptionTransportMedium	TransportMedium `[get]`
	Gets SubscriptionTransportMedium.LocalFile More...

bool	EndOfStream `[get]`
	Gets whether or not there's more data to be read in the stream More...

Properties inherited from QuantConnect.Interfaces.IStreamReader
SubscriptionTransportMedium	TransportMedium `[get]`
	Gets the transport medium of this stream reader More...

bool	EndOfStream `[get]`
	Gets whether or not there's more data to be read in the stream More...

StreamReader	StreamReader `[get]`
	Direct access to the StreamReader instance More...

bool	ShouldBeRateLimited `[get]`
	Gets whether or not this stream reader should be rate limited More...

Detailed Description

Represents a stream reader capable of reading lines from disk

Constructor & Destructor Documentation

QuantConnect.Lean.Engine.DataFeeds.Transport.LocalFileSubscriptionStreamReader.LocalFileSubscriptionStreamReader	(	IDataCacheProvider	dataCacheProvider,
		string	source,
		string	entryName = `null`
	)

Initializes a new instance of the LocalFileSubscriptionStreamReader class.

Parameters

dataCacheProvider	The IDataCacheProvider used to retrieve a stream of data
source	The local file to be read
entryName	Specifies the zip entry to be opened. Leave null if not applicable, or to open the first zip entry found regardless of name

Here is the call graph for this function:

QuantConnect.Lean.Engine.DataFeeds.Transport.LocalFileSubscriptionStreamReader.LocalFileSubscriptionStreamReader	(	IDataCacheProvider	dataCacheProvider,
		string	source,
		long	startingPosition
	)

Initializes a new instance of the LocalFileSubscriptionStreamReader class.

Parameters

dataCacheProvider	The IDataCacheProvider used to retrieve a stream of data
source	The local file to be read
startingPosition	The position in the stream from which to start reading

Here is the call graph for this function:

QuantConnect.Lean.Engine.DataFeeds.Transport.LocalFileSubscriptionStreamReader.LocalFileSubscriptionStreamReader	(	ZipFile	zipFile,
		string	entryName = `null`
	)

Initializes a new instance of the LocalFileSubscriptionStreamReader class.

Parameters

zipFile	The local zip archive to be read
entryName	Specifies the zip entry to be opened. Leave null if not applicable, or to open the first zip entry found regardless of name