ATAS.DataFeedsCore.QueueAsyncWrap Class Reference

Allows to use the power of async / await in compatible way with IQueue interface. More...

Inheritance diagram for ATAS.DataFeedsCore.QueueAsyncWrap:

Collaboration diagram for ATAS.DataFeedsCore.QueueAsyncWrap:

Classes
class	AsyncAwaiterFacade
	Facade for SynchronizationContextAwaiter to allow explicit call of SwitchToQueueThreadAsync() More...
class	QueueSynchronizationContext
	Custom synchronization context to forward await continuations to the connector queue. More...
struct	SynchronizationContextAwaiter
	Custom awaiter to control continuation execution on the QueueSynchronizationContext More...

Public Member Functions
AsyncAwaiterFacade	SwitchToQueueThreadAsync ()
	QueueAsyncWrap (IQueue queueToWrap)
void	Process (IQueueItem item)
void	ProcessHeartbeat ()

Properties
int	QueueThreadId [get]
	Gets the ManagerThreadId of the Queue thread.
SynchronizationContext	SynchronizationContext [get]
TimeSpan	HeartbeatTimeout [get]

Detailed Description

Allows to use the power of async / await in compatible way with IQueue interface.

Constructor & Destructor Documentation

QueueAsyncWrap()

ATAS.DataFeedsCore.QueueAsyncWrap.QueueAsyncWrap

(

IQueue

queueToWrap

)

Member Function Documentation

Process()

void ATAS.DataFeedsCore.QueueAsyncWrap.Process

(

IQueueItem

item

)

ProcessHeartbeat()

void ATAS.DataFeedsCore.QueueAsyncWrap.ProcessHeartbeat

(

)

SwitchToQueueThreadAsync()

AsyncAwaiterFacade ATAS.DataFeedsCore.QueueAsyncWrap.SwitchToQueueThreadAsync

(

)

Property Documentation

HeartbeatTimeout

TimeSpan ATAS.DataFeedsCore.QueueAsyncWrap.HeartbeatTimeout

get

QueueThreadId

int ATAS.DataFeedsCore.QueueAsyncWrap.QueueThreadId

get

Gets the ManagerThreadId of the Queue thread.

SynchronizationContext

SynchronizationContext ATAS.DataFeedsCore.QueueAsyncWrap.SynchronizationContext

get

---

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

• QueueAsyncWrap.cs