anchor.diff:  ﻿namespace MBrace.Flow
   
  +open System
   open System.IO
   open System.Collections
   open System.Collections.Generic
  
positive.code:     member __.Item with get i = partitions.[i]
  
      /// Caching level for persisted data
      member __.StorageLevel = partitions |> Array.fold (fun s (_,cv) -> s ||| cv.StorageLevel) Unchecked.defaultof<StorageLevel>
  
      /// Gets the CloudSequence partitions of the PersistedCloudFlow
      member __.Partitions = partitions
  
negative.code:         member cv.PartitionCount: Async<int> = async { return partitions.Length }
          member cv.ToEnumerable() = async { return cv.ToEnumerable() }
  
      interface CloudFlow<'T> with
          member cv.DegreeOfParallelism = None
          member cv.WithEvaluators(collectorf : Local<Collector<'T,'S>>) (projection: 'S -> Local<'R>) (combiner: 'R [] -> Local<'R>): Cloud<'R> = cloud {
              let flow = CloudCollection.ToCloudFlow(cv)
              return! flow.WithEvaluators collectorf projection combiner
          }
  
      interface ICloudDisposable with
          member __.Dispose () = async {
              return!
                  partitions
                  |> Array.map (fun (_,p) -> (p :> ICloudDisposable).Dispose())
                  |> Async.Parallel
                  |> Async.Ignore
          }
  
      override __.ToString() = sprintf "PersistedCloudFlow[%O] of %d partitions." typeof<'T> partitions.Length
  