| OLD | NEW |
| 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 library mocks; | 5 library mocks; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 import 'dart:io'; | 8 import 'dart:io'; |
| 9 | 9 |
| 10 @MirrorsUsed(targets: 'mocks', override: '*') | 10 @MirrorsUsed(targets: 'mocks', override: '*') |
| (...skipping 110 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 121 String toString() { | 121 String toString() { |
| 122 return "NoResponseException after request ${request.toJson()}"; | 122 return "NoResponseException after request ${request.toJson()}"; |
| 123 } | 123 } |
| 124 } | 124 } |
| 125 | 125 |
| 126 /** | 126 /** |
| 127 * A mock [ServerCommunicationChannel] for testing [AnalysisServer]. | 127 * A mock [ServerCommunicationChannel] for testing [AnalysisServer]. |
| 128 */ | 128 */ |
| 129 class MockServerChannel implements ServerCommunicationChannel { | 129 class MockServerChannel implements ServerCommunicationChannel { |
| 130 StreamController<Request> requestController = new StreamController<Request>(); | 130 StreamController<Request> requestController = new StreamController<Request>(); |
| 131 StreamController<Response> responseController = new StreamController<Response>
(); | 131 StreamController<Response> responseController = new StreamController<Response>
.broadcast(); |
| 132 StreamController<Notification> notificationController = new StreamController<N
otification>(sync: true); | 132 StreamController<Notification> notificationController = new StreamController<N
otification>(sync: true); |
| 133 | 133 |
| 134 List<Response> responsesReceived = []; | 134 List<Response> responsesReceived = []; |
| 135 List<Notification> notificationsReceived = []; | 135 List<Notification> notificationsReceived = []; |
| 136 bool _closed = false; | 136 bool _closed = false; |
| 137 | 137 |
| 138 MockServerChannel() { | 138 MockServerChannel() { |
| 139 } | 139 } |
| 140 | 140 |
| 141 @override | 141 @override |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 186 } | 186 } |
| 187 | 187 |
| 188 Future<Response> waitForResponse(Request request) { | 188 Future<Response> waitForResponse(Request request) { |
| 189 String id = request.id; | 189 String id = request.id; |
| 190 pumpEventQueue().then((_) { | 190 pumpEventQueue().then((_) { |
| 191 responseController.addError(new NoResponseException(request)); | 191 responseController.addError(new NoResponseException(request)); |
| 192 }); | 192 }); |
| 193 return responseController.stream.firstWhere((response) { | 193 return responseController.stream.firstWhere((response) { |
| 194 return response.id == id; | 194 return response.id == id; |
| 195 }); | 195 }); |
| 196 // return responseController.stream.firstWhere((response) { |
| 197 // return response.id == id; |
| 198 // }); |
| 196 } | 199 } |
| 197 | 200 |
| 198 @override | 201 @override |
| 199 void close() { | 202 void close() { |
| 200 _closed = true; | 203 _closed = true; |
| 201 } | 204 } |
| 202 } | 205 } |
| 203 | 206 |
| 204 /** | 207 /** |
| 205 * A mock [AnalysisContext] for testing [AnalysisServer]. | 208 * A mock [AnalysisContext] for testing [AnalysisServer]. |
| (...skipping 146 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 352 Set<String> dependencies = new Set<String>(); | 355 Set<String> dependencies = new Set<String>(); |
| 353 | 356 |
| 354 @override | 357 @override |
| 355 PackageMapInfo computePackageMap(resource.Folder folder) { | 358 PackageMapInfo computePackageMap(resource.Folder folder) { |
| 356 if (packageMaps != null) { | 359 if (packageMaps != null) { |
| 357 return new PackageMapInfo(packageMaps[folder.path], dependencies); | 360 return new PackageMapInfo(packageMaps[folder.path], dependencies); |
| 358 } | 361 } |
| 359 return new PackageMapInfo(packageMap, dependencies); | 362 return new PackageMapInfo(packageMap, dependencies); |
| 360 } | 363 } |
| 361 } | 364 } |
| OLD | NEW |