Project Name File Name Usage Source Code Link
nCQRS Pipeline.cs _preDemultiplexingQueue.GetConsumingEnumerable((CancellationToken) cancellationToken) Link To Source File
nCQRS Pipeline.cs _preProcessingQueue.GetConsumingEnumerable((CancellationToken)cancellationToken) Link To Source File
nCQRS Pipeline.cs _postProcessingQueue.GetConsumingEnumerable((CancellationToken)cancellationToken) Link To Source File
Super2013 Pipeline.cs _preDemultiplexingQueue.GetConsumingEnumerable((CancellationToken) cancellationToken) Link To Source File
Super2013 Pipeline.cs _preProcessingQueue.GetConsumingEnumerable((CancellationToken)cancellationToken) Link To Source File
Super2013 Pipeline.cs _postProcessingQueue.GetConsumingEnumerable((CancellationToken)cancellationToken) Link To Source File
InfinityMQ PrimitiveObjectPool.cs this.queue.GetConsumingEnumerable(this.cancellationTokenSource.Token) Link To Source File
lokad-cloud-apphost Host.cs _commandQueue.GetConsumingEnumerable(cancellationToken) Link To Source File
ncqrs Pipeline.cs _preDemultiplexingQueue.GetConsumingEnumerable((CancellationToken) cancellationToken) Link To Source File
ncqrs Pipeline.cs _preProcessingQueue.GetConsumingEnumerable((CancellationToken)cancellationToken) Link To Source File
ncqrs Pipeline.cs _postProcessingQueue.GetConsumingEnumerable((CancellationToken)cancellationToken) Link To Source File
Roger QueueingPublishingProcess.cs publishingQueue.GetConsumingEnumerable(tokenSource.Token) Link To Source File