Project Name File Name Usage Source Code Link
doc-db VowelCalc.cs resultCollection.Add(reduce(reduceItem)) Link To Source File
nCQRS Pipeline.cs _preProcessingQueue.Add(e.DemultiplexedElement) Link To Source File
nCQRS Pipeline.cs _preDemultiplexingQueue.Add(() => _demultiplexer.MarkAsProcessed(e.ProcessedElement)) Link To Source File
nCQRS Pipeline.cs _postProcessingQueue.Add(e.ProcessedElement) Link To Source File
nCQRS Pipeline.cs _preDemultiplexingQueue.Add(() => _demultiplexer.Demultiplex(e.ProcessingElement)) Link To Source File
Super2013 Pipeline.cs _preProcessingQueue.Add(e.DemultiplexedElement) Link To Source File
Super2013 Pipeline.cs _preDemultiplexingQueue.Add(() => _demultiplexer.MarkAsProcessed(e.ProcessedElement)) Link To Source File
Super2013 Pipeline.cs _postProcessingQueue.Add(e.ProcessedElement) Link To Source File
Super2013 Pipeline.cs _preDemultiplexingQueue.Add(() => _demultiplexer.Demultiplex(e.ProcessingElement)) Link To Source File
SisoDb-Provider ServiceStackJsonSerializer.cs q.Add(json) Link To Source File
Filechronization QueingThread.cs queue.Add(comm) Link To Source File
InfinityMQ PrimitiveObjectPool.cs this.queue.Add(item) Link To Source File
InfinityMQ PrimitiveObjectPool.cs this.queue.Add(e) Link To Source File
learning MemoizingMRUCache.cs concurrentOps.Add(key) Link To Source File
lokad-cloud-apphost Host.cs _commandQueue.Add(new LoadCurrentHeadDeploymentCommand()) Link To Source File
lokad-cloud-apphost Host.cs _commandQueue.Add(new EnsureAllCellsAreRunningUnlessCancelledCommand()) Link To Source File
lokad-cloud-apphost Host.cs _commandQueue.Add(new LoadCurrentHeadDeploymentCommand()) Link To Source File
lokad-cloud-apphost Host.cs _commandQueue.Add(new EnsureAllCellsAreRunningUnlessCancelledCommand()) Link To Source File
lokad-cqrs MemoryPartitionInbox.cs _queues[id].Add(context.Unpacked) Link To Source File
lokad-cqrs MemoryQueueWriter.cs _queue.Add(envelope) Link To Source File
nuget ConsoleDispatcher.cs _keyBuffer.Add(key) Link To Source File
SwarmIntelligence BlockingCollectionExtensions.cs target.Add(item) Link To Source File
SwarmIntelligence BlockingCollectionExtensions.cs target.Add(item) Link To Source File
NugetCracker ConsoleDispatcher.cs _keyBuffer.Add(key) Link To Source File
ncqrs Pipeline.cs _preProcessingQueue.Add(e.DemultiplexedElement) Link To Source File
ncqrs Pipeline.cs _preDemultiplexingQueue.Add(() => _demultiplexer.MarkAsProcessed(e.ProcessedElement)) Link To Source File
ncqrs Pipeline.cs _postProcessingQueue.Add(e.ProcessedElement) Link To Source File
ncqrs Pipeline.cs _preDemultiplexingQueue.Add(() => _demultiplexer.Demultiplex(e.ProcessingElement)) Link To Source File
Disruptor-net DiamondPath1P3CBlockingCollectionPerfTest.cs _fizzInputQueue.Add(i) Link To Source File
Disruptor-net DiamondPath1P3CBlockingCollectionPerfTest.cs _buzzInputQueue.Add(i) Link To Source File
Disruptor-net Pipeline3StepLatencyBlockingCollectionPerfTest.cs _stepOneQueue.Add(Stopwatch.GetTimestamp()) Link To Source File
Disruptor-net MultiCast1P3CBlockingCollectionPerfTest.cs _blockingQueues[0].Add(i) Link To Source File
Disruptor-net MultiCast1P3CBlockingCollectionPerfTest.cs _blockingQueues[1].Add(i) Link To Source File
Disruptor-net MultiCast1P3CBlockingCollectionPerfTest.cs _blockingQueues[2].Add(i) Link To Source File
Disruptor-net Pipeline3StepBlockingCollectionPerfTest.cs _stepOneQueue.Add(values) Link To Source File
Disruptor-net FizzBuzzQueueEventProcessor.cs _fizzOutputQueue.Add((value % 3) == 0) Link To Source File
Disruptor-net FizzBuzzQueueEventProcessor.cs _buzzOutputQueue.Add((value % 5) == 0) Link To Source File
Disruptor-net FunctionQueueEventProcessor.cs _stepTwoQueue.Add(values[0] + values[1]) Link To Source File
Disruptor-net FunctionQueueEventProcessor.cs _stepThreeQueue.Add(value + 3) Link To Source File
Disruptor-net LatencyStepQueueEventProcessor.cs _outputQueue.Add(_inputQueue.Take()) Link To Source File
Disruptor-net ValueQueueProducer.cs _blockingQueue.Add(i) Link To Source File
Disruptor-net UniCast1P1CBlockingCollectionPerfTest.cs _queue.Add(i) Link To Source File
Disruptor-net RoundRobinThreadAffinedTaskScheduler.cs _tasks.Add(task) Link To Source File
OG-DotNet RemoteViewClientExtensions.cs resultQueue.Add(e) Link To Source File
OG-DotNet RemoteViewClientExtensions.cs otherQueue.Add(e) Link To Source File
OG-DotNet RemoteViewClientExtensions.cs otherQueue.Add(e) Link To Source File
OG-DotNet RemoteViewClientExtensions.cs otherQueue.Add(e) Link To Source File
OG-DotNet RemoteViewClientTests.cs compilationResult.Add(e.CompiledViewDefinition) Link To Source File
OG-DotNet RemoteViewClientTests.cs compilationResult.Add(e.Exception) Link To Source File
OG-DotNet RemoteViewClientTests.cs compilationResult.Add(e.CompiledViewDefinition) Link To Source File
OG-DotNet RemoteViewClientTests.cs compilationError.Add(e.Exception) Link To Source File
OG-DotNet RemoteViewCycleTests.cs cycles.Add(null) Link To Source File
OG-DotNet RemoteViewCycleTests.cs cycles.Add(null) Link To Source File
OG-DotNet RemoteViewCycleTests.cs cycles.Add(null) Link To Source File
OG-DotNet RemoteViewCycleTests.cs cycles.Add(remoteViewClient.CreateCycleReference(e.FullResult.ViewCycleId)) Link To Source File
OG-DotNet RemoteViewCycleTests.cs cycles.Add(remoteViewClient.CreateCycleReference(e.FullResult.ViewCycleId)) Link To Source File
OG-DotNet FreezeDetector.cs postedOperations.Add(e.Operation) Link To Source File
ravendb TaskSchedulerWithCustomPriority.cs _tasks.Add(task) Link To Source File
ravendb ProcessDriver.cs output.Add(line) Link To Source File
ravendb ProcessDriver.cs error.Add(line) Link To Source File
Roger QueueingPublishingProcess.cs publishingQueue.Add(factory) Link To Source File
Roger ChatServer.cs messages.Add(message) Link To Source File
Disruptor.NET Pipeline3StepLatencyPerfTest.cs stepOneQueue.Add(_stopwatch.GetElapsedNanoSeconds()) Link To Source File
Disruptor.NET Pipeline3StepPerfTest.cs stepOneQueue.Add(values) Link To Source File
Disruptor.NET FunctionQueueConsumer.cs stepTwoQueue.Add(values[0] + values[1]) Link To Source File
Disruptor.NET FunctionQueueConsumer.cs stepThreeQueue.Add(value + 3L) Link To Source File
Disruptor.NET LatencyStepQueueConsumer.cs outputQueue.Add(inputQueue.Take()) Link To Source File
WCell BlockingCollectionExtensions.cs target.Add(item) Link To Source File
WCell BlockingCollectionExtensions.cs target.Add(item) Link To Source File