anchor.diff:                          Cts = new CancellationTokenSource()   }
                   member self.Result = 
                       let stream' = dict |> ofSeq |> map (fun keyValue -> (keyValue.Key, keyValue.Value :> seq<'T>))   
  -                    stream' |> withDegreeOfParallelism !stream.DegreeOfParallelism }
  -
  -        let stream = if stream.PreserveOrdering then stream.Stream() |> Stream.toSeq |> ofSeq |> withDegreeOfParallelism !stream.DegreeOfParallelism else stream
  +                    stream' |> withDegreeOfParallelism stream.DegreeOfParallelism }
  +
  +        let stream = if stream.PreserveOrdering then stream.Stream() |> Stream.toSeq |> ofSeq |> withDegreeOfParallelism stream.DegreeOfParallelism else stream
           stream.Apply collector
           
   
  
positive.code: type SourceType = Array | ResizeArray | Seq
  
  /// Represents a parallel Stream of values.
  type ParStream<'T> =
      /// The number of concurrently executing tasks
      abstract DegreeOfParallelism : int ref
      /// The Type of iteration source
      abstract SourceType : SourceType
      /// A flag that indicates that the ordering in the subsequent query operators will be preserved.
  
negative.code:     /// <param name="source">The input array.</param>
      /// <returns>The result parallel stream.</returns>
      let ofResizeArray (source : ResizeArray<'T>) : ParStream<'T> =
          { new ParStream<'T> with
              member self.DegreeOfParallelism = Environment.ProcessorCount
              member self.SourceType = SourceType.ResizeArray
              member self.PreserveOrdering = false
              member self.Stream () = Stream.ofResizeArray source
              member self.Apply<'R> (collector : Collector<'T, 'R>) =
                  if not (source.Count = 0) then 
                      let partitions = getPartitions collector.DegreeOfParallelism source.Count
                      let nextRef = ref true
                      let createTask s e (iter : ParIterator<'T>) = 
                          iter.Cts.Token.Register(fun _ -> nextRef := false) |> ignore 
  