anchor.diff:     
       member x.WaitAll = queue.AsyncComplete
   
  -    member x.StartWork () = writeQueue.StartWork()+    member x.StartWork () = 
  +        writeQueue.StartWork()
  +        queue.StartWork()
positive.code:         |> Async.Parallel
          |> Async.Ignore
  
      let queue = new WorktrackingQueue<_,_,_>(grouper, processEvent, maxEventQueueSize, eventWorkers, eventComplete);
  
      let positionDocumentKey = "EventProcessingPosition"
  
  
negative.code:     let batchWritesMeter = Metric.Meter(sprintf "BatchWrites %s" databaseName, Unit.Items)
      let batchConflictsMeter = Metric.Meter(sprintf "BatchConflicts %s" databaseName, Unit.Items)
  
      let writeDocs docs = async {
          let sw = System.Diagnostics.Stopwatch.StartNew()
          let batchId = Guid.NewGuid()
          let originalDocMap = 
  