ATAS.DataFeedsCore.ConnectorWebsocket.TaskQueue Class Reference

Public Member Functions
	TaskQueue (int requestPerPeriod, TimeSpan period, bool strictSequence=true)
	Task queue with execution frequency.
async Task< bool >	WaitAsync (bool stopOnError=false)
void	Add (Func< Task > action, bool highPriority=false)
void	Clear ()

Properties
int	Count [get]

Events
Action< Exception >	QueueError

Constructor & Destructor Documentation

TaskQueue()

ATAS.DataFeedsCore.ConnectorWebsocket.TaskQueue.TaskQueue	(	int	requestPerPeriod,
		TimeSpan	period,
		bool	strictSequence = true
	)

Task queue with execution frequency.

Parameters

requestPerPeriod	Run execution limit per period
period	Period of limit
strictSequence	Next task is run after previous completion

Member Function Documentation

Add()

void ATAS.DataFeedsCore.ConnectorWebsocket.TaskQueue.Add	(	Func< Task >	action,
		bool	highPriority = false
	)

Clear()

void ATAS.DataFeedsCore.ConnectorWebsocket.TaskQueue.Clear

(

)

WaitAsync()

async Task< bool > ATAS.DataFeedsCore.ConnectorWebsocket.TaskQueue.WaitAsync

(

bool

stopOnError = false

)

Property Documentation

Count

int ATAS.DataFeedsCore.ConnectorWebsocket.TaskQueue.Count

get

Event Documentation

QueueError

Action<Exception> ATAS.DataFeedsCore.ConnectorWebsocket.TaskQueue.QueueError

---

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

• TaskQueue.cs