OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 part of bindings; | 5 part of bindings; |
6 | 6 |
7 class ProxyCloseException { | 7 class ProxyCloseException { |
8 final String message; | 8 final String message; |
9 ProxyCloseException(this.message); | 9 ProxyCloseException(this.message); |
10 String toString() => message; | 10 String toString() => message; |
(...skipping 29 matching lines...) Expand all Loading... |
40 assert(result.status.isOk || result.status.isResourceExhausted); | 40 assert(result.status.isOk || result.status.isResourceExhausted); |
41 var message = new ServiceMessage.fromMessage(new Message(bytes, handles)); | 41 var message = new ServiceMessage.fromMessage(new Message(bytes, handles)); |
42 handleResponse(message); | 42 handleResponse(message); |
43 } | 43 } |
44 | 44 |
45 void handleWrite() { | 45 void handleWrite() { |
46 throw 'Unexpected write signal in proxy.'; | 46 throw 'Unexpected write signal in proxy.'; |
47 } | 47 } |
48 | 48 |
49 @override | 49 @override |
50 Future close({bool nodefer: false}) { | 50 Future close({bool immediate: false}) { |
51 for (var completer in _completerMap.values) { | 51 for (var completer in _completerMap.values) { |
52 completer.completeError(new ProxyCloseException('Proxy closed')); | 52 completer.completeError(new ProxyCloseException('Proxy closed')); |
53 } | 53 } |
54 _completerMap.clear(); | 54 _completerMap.clear(); |
55 return super.close(nodefer: nodefer); | 55 return super.close(immediate: immediate); |
56 } | 56 } |
57 | 57 |
58 void sendMessage(Struct message, int name) { | 58 void sendMessage(Struct message, int name) { |
59 if (!isOpen) { | 59 if (!isOpen) { |
60 listen(); | 60 listen(); |
61 } | 61 } |
62 var header = new MessageHeader(name); | 62 var header = new MessageHeader(name); |
63 var serviceMessage = message.serializeWithHeader(header); | 63 var serviceMessage = message.serializeWithHeader(header); |
64 endpoint.write(serviceMessage.buffer, | 64 endpoint.write(serviceMessage.buffer, |
65 serviceMessage.buffer.lengthInBytes, serviceMessage.handles); | 65 serviceMessage.buffer.lengthInBytes, serviceMessage.handles); |
(...skipping 30 matching lines...) Expand all Loading... |
96 var superString = super.toString(); | 96 var superString = super.toString(); |
97 return "Proxy(${superString})"; | 97 return "Proxy(${superString})"; |
98 } | 98 } |
99 } | 99 } |
100 | 100 |
101 // Generated Proxy classes implement this interface. | 101 // Generated Proxy classes implement this interface. |
102 abstract class ProxyBase { | 102 abstract class ProxyBase { |
103 final Proxy impl = null; | 103 final Proxy impl = null; |
104 final String name = null; | 104 final String name = null; |
105 } | 105 } |
OLD | NEW |