| Index: runtime/bin/vmservice/message.dart
|
| diff --git a/runtime/bin/vmservice/message.dart b/runtime/bin/vmservice/message.dart
|
| deleted file mode 100644
|
| index 9dce2a1d2b6bf23d3adb239c3711230d3670e704..0000000000000000000000000000000000000000
|
| --- a/runtime/bin/vmservice/message.dart
|
| +++ /dev/null
|
| @@ -1,82 +0,0 @@
|
| -// Copyright (c) 2013, 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.
|
| -
|
| -part of vmservice;
|
| -
|
| -class Message {
|
| - final Completer _completer = new Completer.sync();
|
| - bool get completed => _completer.isCompleted;
|
| - /// Future of response.
|
| - Future<String> get response => _completer.future;
|
| - /// Path.
|
| - final List<String> path = new List<String>();
|
| - /// Options.
|
| - final Map<String, String> options = new Map<String, String>();
|
| -
|
| - void _setPath(List<String> pathSegments) {
|
| - if (pathSegments == null) {
|
| - return;
|
| - }
|
| - pathSegments.forEach((String segment) {
|
| - if (segment == null || segment == '') {
|
| - return;
|
| - }
|
| - path.add(segment);
|
| - });
|
| - }
|
| -
|
| - Message.fromUri(Uri uri) {
|
| - var split = uri.path.split('/');
|
| - if (split.length == 0) {
|
| - setErrorResponse('Invalid uri: $uri.');
|
| - return;
|
| - }
|
| - _setPath(split);
|
| - options.addAll(uri.queryParameters);
|
| - }
|
| -
|
| - Message.fromMap(Map map) {
|
| - _setPath(map['path']);
|
| - if (map['options'] != null) {
|
| - options.addAll(map['options']);
|
| - }
|
| - }
|
| -
|
| - dynamic toJson() {
|
| - return {
|
| - 'path': path,
|
| - 'options': options
|
| - };
|
| - }
|
| -
|
| - Future<String> send(SendPort sendPort) {
|
| - final receivePort = new RawReceivePort();
|
| - receivePort.handler = (value) {
|
| - receivePort.close();
|
| - if (value is Exception) {
|
| - _completer.completeError(value);
|
| - } else {
|
| - _completer.complete(value);
|
| - }
|
| - };
|
| - var keys = options.keys.toList();
|
| - var values = options.values.toList();
|
| - var request = [receivePort.sendPort, path, keys, values];
|
| - sendServiceMessage(sendPort, request);
|
| - return _completer.future;
|
| - }
|
| -
|
| - void setResponse(String response) {
|
| - _completer.complete(response);
|
| - }
|
| -
|
| - void setErrorResponse(String error) {
|
| - _completer.complete(JSON.encode({
|
| - 'type': 'Error',
|
| - 'msg': error,
|
| - 'path': path,
|
| - 'options': options
|
| - }));
|
| - }
|
| -}
|
|
|