anchor.diff:    NotifyPipelineAppended(AStage);
   end;
   
  -procedure TPipelineQueue<T>.Enqueue(const AItem : T); overload;
  +procedure TPipelineQueue<T>.Enqueue(const AItem : T);
   begin
     Enqueue(0, AItem);
   end;
   
  -procedure TPipelineQueue<T>.EnqueueRange(const AItems : array of T); overload;
  +procedure TPipelineQueue<T>.EnqueueRange(const AItems : array of T);
   begin
     EnqueueRange(0, AItems);
   end;
  
positive.code:     { TErrorResult }
  
      TErrorResult = record
        Item : T;
        ErrorMessage : String;
      end;
  
      { TPipelineWorkerThread}
  
negative.code: begin
    if (FActiveWorkerThreads = 0) OR (FActiveWorkerThreads < FMaxWorkerThreads) then begin
      // Start a new worker thread to process
      TPipelineWorkerThread.Create(Self, AStage);
      {$IFDEF UNITTESTS}
      if (FActiveWorkerThreads > FHistoricalMaxActiveWorkerThreads) then
  