anchor.diff:      return controller.stream;
     }
   
  -  /// Merges two streams into one stream by using the selector function whenever one of the streams produces an event.
  -  /// The merged stream will complete if:
  -  /// * both input streams have completed
  -  /// * [closeOnError] flag is set to true and an error is received
  +  /**
  +   * Merges two streams into one by using the selector function to generate new elements whenever one of the input streams produces a new element.
  +   *
  +   * The merged stream will complete if:
  +   *
  +   * * both input streams have completed
  +   * * [closeOnError] flag is set to true and an error is received
  +   */
     static Stream combineLatest(Stream stream1, Stream stream2, dynamic selector(dynamic item1, dynamic item2), { bool closeOnError : false, bool sync : false }) {
       var controller = new StreamController.broadcast(sync : sync);
       var completer1 = new Completer();
  
positive.code:     if (!controller.isClosed) controller.add(event);
    }
  
    /// Merges two stream into one, the merged stream will forward any events and errors received from the input
    /// streams. The merged stream will complete if:
    /// * both input streams have completed
    /// * [closeOnError] flag is set to true and an error is received
    static Stream merge(Stream stream1, Stream stream2, { bool closeOnError : false, bool sync : false }) {
      var controller = new StreamController.broadcast(sync : sync);
      var completer1 = new Completer();
  
negative.code:     return controller.stream;
    }
  
    /**
     * Projects each element from the input stream into consecutive non-overlapping windows.
     *
     * Each element produced by the output stream will contains a list of elements up to the specified count.
     *
     * The output stream will complete if:
     *
     * * the input stream has completed and any buffered elements have been pushed
     * * [closeOnError] flag is set to true and an error is received
     */
    static Stream window(Stream input, int count, { bool closeOnError : false, bool sync : false }) {
      var controller = new StreamController.broadcast(sync : sync);
      var onError    = _getOnErrorHandler(controller, closeOnError);
  