anchor.diff:          return arrayCollector.ToArray()
       }
   
  +    //static let workerGuid = Guid.NewGuid().ToString()
       /// <summary>Returns an array of line separated CloudFiles from the given CloudFlow of strings.</summary>
       /// <param name="dirPath">The directory where the cloudfiles are going to be saved.</param>
       /// <param name="flow">The input CloudFlow.</param>
  
positive.code: module CloudFlow =
      open System.IO
  
      let inline private run ctx a = Cloud.RunSynchronously(a, ctx.Resources,ctx.CancellationToken)
  
      //#region Intermediate functions
  
negative.code:                     { new Collector<string, CloudFile []> with
                          member self.DegreeOfParallelism = flow.DegreeOfParallelism
                          member self.Iterator() =
                              let path = config.FileStore.Combine(dirPath, sprintf "Part-%s-%d.txt" cloudFlowStaticId results.Count)
                              let stream = config.FileStore.BeginWrite(path) |> Async.RunSynchronously
                              let writer = new StreamWriter(stream)
                              results.Add((path, writer))
  