anchor.diff:  open Nessos.Streams.Internals
   
   /// Represents the iteration function
  -type internal ParIterator<'T> = {
  +type ParIterator<'T> = {
       /// The composed continutation with 'T for the current value
       Func : ('T -> unit)
       /// The current CancellationTokenSource
  
positive.code:     member internal x.DegreeOfParallelism = x.Impl.DegreeOfParallelism
      member internal x.PreserveOrdering = x.Impl.PreserveOrdering
      member internal x.SourceType = x.Impl.SourceType
      member internal x.Apply<'R>(collector: Collector<'T, 'R>) = x.Impl.Apply collector
  
  /// Provides basic operations on Parallel Streams.
  [<RequireQualifiedAccessAttribute>]
  
negative.code:             member self.SourceType = SourceType.ResizeArray
              member self.PreserveOrdering = false
              member self.Stream () = Stream.ofResizeArray source
              member self.Apply<'R> (collector : ParCollector<'T, 'R>) =
                  if not (source.Count = 0) then 
                      let partitions = getPartitions collector.DegreeOfParallelism source.Count
                      let nextRef = ref true
  