anchor.diff:                      let! workerCount = 
                           match !self.DegreeOfParallelism with
                           | Some n -> cloud { return n }
  -                        | None -> Cloud.GetWorkerCount()
  +                        | None -> getWorkerCount()
                       
                       let createTask (partitionId : int) (collector : Cloud<Collector<'T, 'S>>) = 
                           cloud {
  
positive.code: 
      /// Maximum combined stream length used in ofCloudFiles.
      let private maxCloudFileCombinedLength = 1024L * 1024L * 1024L
  
      /// <summary>Wraps array as a CloudStream.</summary>
      /// <param name="source">The input array.</param>
  
negative.code:             cloud {
                  let combiner' (left : CloudArray<_>) (right : CloudArray<_>) = 
                      left.Append(right)
                  let! totalWorkers = match !stream.DegreeOfParallelism with Some n -> cloud { return n } | None -> getWorkerCount()
                  let! keyValueArray = stream.Apply (collectorf totalWorkers) 
                                                    (fun keyValues -> cloud {
                                                          let dict = new Dictionary<int, CloudArray<'Key * 'State>>() 
  