incremental progress reworking code completion manager / computers

pkg/analysis_services/lib/completion/completion_computer.dart

 // Copyright (c) 2014, the Dart project authors.  Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.
 
 library services.completion.computer;
 
 import 'dart:async';
 
 import 'package:analysis_services/completion/completion_suggestion.dart';
 import 'package:analysis_services/search/search_engine.dart';
@@ skipping 11 matching lines @@
    */
   Future<List<CompletionSuggestion>> compute();
 }
 
 /**
  * Manages `CompletionComputer`s for a given completion request.
  */
 abstract class CompletionManager {
 
   /**
+   * Create a manager for the given request.
+   */
+  static CompletionManager create(Source source, int offset,
+      SearchEngine searchEngine) {
+    if (AnalysisEngine.isDartFileName(source.shortName)) {
+      return new DartCompletionManager(source, offset, searchEngine);
+    }
+    return new NoOpCompletionManager(source, offset);
+  }
+
+  StreamController<CompletionResult> controller;
+
+  /**
+   * Generate a stream of code completion results.
+   */
+  Stream<CompletionResult> results() {
+    controller = new StreamController<CompletionResult>(onListen: () {
+      scheduleMicrotask(compute);
+    });
+    return controller.stream;
+  }
+
+  /**
+   * Compute completion results and append them to the stream.
+   */
+  void compute();
+}
+
+/**
+ * Code completion result generated by an [CompletionManager].
+ */
+class CompletionResult {
+
+  /**
    * The length of the text to be replaced if the remainder of the identifier
    * containing the cursor is to be replaced when the suggestion is applied
    * (that is, the number of characters in the existing identifier).
    */
-  int get replacementLength;
+  final int replacementLength;
 
   /**
    * The offset of the start of the text to be replaced. This will be different
    * than the offset used to request the completion suggestions if there was a
    * portion of an identifier before the original offset. In particular, the
    * replacementOffset will be the offset of the beginning of said identifier.
    */
-  int get replacementOffset;
+  final int replacementOffset;
 
   /**
-   * Generate code completion computers for the given situation.
+   * The suggested completions.
    */
-  Future<List<CompletionComputer>> generate();
+  final List<CompletionSuggestion> suggestions;
 
   /**
-   * Create a manager for the given request.
+   * `true` if this is that last set of results that will be returned
+   * for the indicated completion.
    */
-  static CompletionManager create(Source source, int offset,
-      SearchEngine searchEngine) {
-    if (AnalysisEngine.isDartFileName(source.shortName)) {
-      return new DartCompletionManager(source, offset, searchEngine);
-    }
-    return new NoOpCompletionManager(source, offset);
-  }
+  final bool last;
+
+  CompletionResult(this.replacementOffset, this.replacementLength,
+      this.suggestions, this.last);
 }
 
 /**
  * Manages code completion for a given Dart file completion request.
  */
 class DartCompletionManager extends CompletionManager {
   final Source source;
   final int offset;
   final SearchEngine searchEngine;
 
   DartCompletionManager(this.source, this.offset, this.searchEngine);
 
   @override
-  int get replacementLength => 0;
-
-  @override
-  int get replacementOffset => offset;
-
-  @override
-  Future<List<CompletionComputer>> generate() {
-    List<CompletionComputer> computers = [];
-    computers.add(new TopLevelComputer(searchEngine));
-    return new Future.value(computers);
+  void compute() {
+    var computer = new TopLevelComputer(searchEngine);
+    computer.compute().then((List<CompletionSuggestion> suggestions) {
+      controller.add(new CompletionResult(offset, 0, suggestions, true));
+    });
   }
 }
 
-class NoOpCompletionComputer extends CompletionComputer {
-  @override
-  Future<List<CompletionSuggestion>> compute() {
-    return new Future.value([]);
-  }
-}
-
 class NoOpCompletionManager extends CompletionManager {
   final Source source;
   final int offset;
 
   NoOpCompletionManager(this.source, this.offset);
 
   @override
-  int get replacementLength => 0;
-
-  @override
-  int get replacementOffset => offset;
-
-  @override
-  Future<List<CompletionComputer>> generate() {
-    return new Future.value([new NoOpCompletionComputer()]);
+  void compute() {
+    controller.add(new CompletionResult(offset, 0, [], true));
   }
 }