anchor.diff:              cloud {
                   let combiner' (left : CloudArray<_>) (right : CloudArray<_>) = 
                       left.Append(right)
  -                let! totalWorkers = match !stream.DegreeOfParallelism with Some n -> cloud { return n } | None -> Cloud.GetWorkerCount()
  +                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>>() 
  
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:     /// <param name="source">The input CloudArray.</param>
      let cache (source : CloudArray<'T>) : Cloud<CloudArray<'T>> = 
          cloud {
              let! workerCount = getWorkerCount()
              let createTask (pid : int) (cached : CachedCloudArray<'T>) = 
                  cloud {
                      let! slice = (cached :> CloudArray<'T>).GetPartition(pid)
  