| OLD | NEW |
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, 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 part of vmservice; | 5 part of vmservice; |
| 6 | 6 |
| 7 class RunningIsolate implements ServiceRequestRouter { | 7 class RunningIsolate implements MessageRouter { |
| 8 final int portId; | 8 final int portId; |
| 9 final SendPort sendPort; | 9 final SendPort sendPort; |
| 10 final String name; | 10 final String name; |
| 11 | 11 |
| 12 RunningIsolate(this.portId, this.sendPort, this.name); | 12 RunningIsolate(this.portId, this.sendPort, this.name); |
| 13 | 13 |
| 14 Future sendMessage(List request) { | 14 Future<String> route(Message message) { |
| 15 final completer = new Completer.sync(); | |
| 16 final receivePort = new RawReceivePort(); | |
| 17 sendServiceMessage(sendPort, receivePort, request); | |
| 18 receivePort.handler = (value) { | |
| 19 receivePort.close(); | |
| 20 if (value is Exception) { | |
| 21 completer.completeError(value); | |
| 22 } else { | |
| 23 completer.complete(value); | |
| 24 } | |
| 25 }; | |
| 26 return completer.future; | |
| 27 } | |
| 28 | |
| 29 Future route(ServiceRequest request) { | |
| 30 // Send message to isolate. | 15 // Send message to isolate. |
| 31 var message = request.toServiceCallMessage(); | 16 return message.send(sendPort); |
| 32 return sendMessage(message).then((response) { | |
| 33 request.setResponse(response); | |
| 34 return new Future.value(request); | |
| 35 }); | |
| 36 } | 17 } |
| 37 } | 18 } |
| OLD | NEW |