anchor.diff:          }
   
       /// <summary>Applies the given locally executing cloud function to successive elements, returning the first result where the function returns a Some value.
  -    /// Raises KeyNotFoundException when every item of the cloud stream evaluates to None when the given function is applied.</summary>
  +    /// Raises KeyNotFoundException when every item of the cloud flow evaluates to None when the given function is applied.</summary>
       /// <param name="chooser">A locally executing cloud function that transforms items into options.</param>
  -    /// <param name="stream">The input cloud stream.</param>
  +    /// <param name="flow">The input cloud flow.</param>
       /// <returns>The first element for which the chooser returns Some, or raises KeyNotFoundException if every element evaluates to None.</returns>
  -    /// <exception cref="System.KeyNotFoundException">Thrown if every item of the cloud stream evaluates to None when the given function is applied.</exception>
  -    let inline pickLocal (chooser : 'T -> Local<'R option>) (stream : CloudFlow<'T>) : Cloud<'R> = 
  -        cloud {
  -            let! result = tryPickLocal chooser stream 
  +    /// <exception cref="System.KeyNotFoundException">Thrown if every item of the cloud flow evaluates to None when the given function is applied.</exception>
  +    let inline pickLocal (chooser : 'T -> Local<'R option>) (flow : CloudFlow<'T>) : Cloud<'R> = 
  +        cloud {
  +            let! result = tryPickLocal chooser flow 
               return 
                   match result with
                   | Some value -> value 
                   | None -> raise <| new KeyNotFoundException()
           }
   
  -    /// <summary>Tests if any element of the stream satisfies the given predicate.</summary>
  +    /// <summary>Tests if any element of the flow satisfies the given predicate.</summary>
       /// <param name="predicate">A function to test each source element for a condition.</param>
  -    /// <param name="stream">The input cloud stream.</param>
  +    /// <param name="flow">The input cloud flow.</param>
       /// <returns>true if any element satisfies the predicate. Otherwise, returns false.</returns>
  -    let inline exists (predicate : 'T -> bool) (stream : CloudFlow<'T>) : Cloud<bool> = 
  -        cloud {
  -            let! result = tryFind predicate stream 
  +    let inline exists (predicate : 'T -> bool) (flow : CloudFlow<'T>) : Cloud<bool> = 
  +        cloud {
  +            let! result = tryFind predicate flow 
               return 
                   match result with
                   | Some value -> true
                   | None -> false
           }
   
  -    /// <summary>Tests if any element of the stream satisfies the given locally executing cloud predicate.</summary>
  +    /// <summary>Tests if any element of the flow satisfies the given locally executing cloud predicate.</summary>
       /// <param name="predicate">A locally executing cloud function to test each source element for a condition.</param>
  -    /// <param name="stream">The input cloud stream.</param>
  +    /// <param name="flow">The input cloud flow.</param>
       /// <returns>true if any element satisfies the predicate. Otherwise, returns false.</returns>
  -    let inline existsLocal (predicate : 'T -> Local<bool>) (stream : CloudFlow<'T>) : Cloud<bool> = 
  -        cloud {
  -            let! result = tryFindLocal predicate stream 
  +    let inline existsLocal (predicate : 'T -> Local<bool>) (flow : CloudFlow<'T>) : Cloud<bool> = 
  +        cloud {
  +            let! result = tryFindLocal predicate flow 
               return 
                   match result with
                   | Some value -> true
  
positive.code:                 let cts = new CancellationTokenSource()
                  return 
                      { new Collector<'T, 'R option> with
                          member self.DegreeOfParallelism = stream.DegreeOfParallelism
                          member self.Iterator() = 
                              {   Index = ref -1; 
                                  Func = (fun value -> match chooser ctx value with Some value' -> resultRef := Some value'; cts.Cancel() | None -> ());
  
negative.code:             let dict = new ConcurrentDictionary<'Key, 'State ref>()
              let! ctx = Cloud.GetExecutionContext()
              return { new Collector<int * CloudVector<'Key * 'State>,  seq<'Key * 'State>> with
                  member self.DegreeOfParallelism = flow.DegreeOfParallelism 
                  member self.Iterator() = 
                      {   Index = ref -1; 
                          Func =
  