Replace AnalysisServerListener with Stream.

pkg/analysis_server/lib/src/edit/edit_domain.dart

Index: pkg/analysis_server/lib/src/edit/edit_domain.dart
diff --git a/pkg/analysis_server/lib/src/edit/edit_domain.dart b/pkg/analysis_server/lib/src/edit/edit_domain.dart
index bf27d38ecea81006b96bebd2347968d9214e22c3..128deed914e4b47d18bde7ad4d1506058fce1119 100644
--- a/pkg/analysis_server/lib/src/edit/edit_domain.dart
+++ b/pkg/analysis_server/lib/src/edit/edit_domain.dart
@@ -20,6 +20,7 @@ import 'package:analyzer/src/generated/element.dart';
 import 'package:analyzer/src/generated/engine.dart' as engine;
 import 'package:analyzer/src/generated/error.dart' as engine;
 import 'package:analyzer/src/generated/source.dart';
+import 'package:analyzer/src/generated/engine.dart';
 
 
 /**
@@ -180,8 +181,7 @@ class _RefactoringManager {
   EditGetRefactoringResult result;
 
   _RefactoringManager(this.server, this.searchEngine) {
-    server.addAnalysisServerListener(
-        new _ResetRefactoringManagerAnalysisServerListener(this));
+    server.onAnalysisStarted.listen(_reset);
     _reset();
   }
 
@@ -374,7 +374,7 @@ class _RefactoringManager {
     });
   }
 
-  void _reset() {
+  void _reset([AnalysisContext context]) {
     kind = null;
     offset = null;
     length = null;
@@ -442,24 +442,3 @@ class _RefactoringManager {
     return new RefactoringStatus();
   }
 }
-
-
-/**
- * A [AnalysisServerListener] that resets [_RefactoringManager] when analysis
- * is started in the [AnalysisServer].
- */
-class _ResetRefactoringManagerAnalysisServerListener implements
-    AnalysisServerListener {
-  final _RefactoringManager refactoringManager;
-
-  _ResetRefactoringManagerAnalysisServerListener(this.refactoringManager);
-
-  @override
-  void analysisComplete() {
-  }
-
-  @override
-  void analysisStarted(engine.AnalysisContext context) {
-    refactoringManager._reset();
-  }
-}