anchor.diff:  ﻿namespace MBrace.Streams
  +
   #nowarn "0443"
   #nowarn "0444"
   
  
positive.code:                                                   (fun keyValues -> cloud {
                                                          let dict = new Dictionary<int, VectorCollector<'Key * 'State>>() 
                                                          for (key, value) in keyValues do
                                                              let! values = VectorCollector.New(value, maxCloudVectorPartitionSize())
                                                              dict.[key] <- values
                                                          let values = dict |> Seq.map (fun keyValue -> (keyValue.Key, keyValue.Value))
                                                          return! VectorCollector.New(values, maxCloudVectorPartitionSize()) }) combiner'
                  
                  let! kva = keyValueArray.ToEnumerable()
                  let dict = 
  
negative.code:     let private maxCloudFileCombinedLength = 1024L * 1024L * 1024L
      
      /// Maximum CloudVector partition size used in CloudVector.New.
      [<Literal>]
      let private maxCloudVectorPartitionSize = 1073741824L // 1GB
  
      /// If local context then returns number of cores instead of throwing exception
      /// else returns number of workers.
  