| 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 library barback.serialize; | 5 library barback.serialize; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 import 'dart:isolate'; | 8 import 'dart:isolate'; |
| 9 | 9 |
| 10 import 'package:stack_trace/stack_trace.dart'; | 10 import 'package:stack_trace/stack_trace.dart'; |
| (...skipping 27 matching lines...) Expand all Loading... |
| 38 | 38 |
| 39 /// Convert a [SendPort] whose opposite is waiting to send us a stream into a | 39 /// Convert a [SendPort] whose opposite is waiting to send us a stream into a |
| 40 /// [Stream]. | 40 /// [Stream]. |
| 41 /// | 41 /// |
| 42 /// No stream data will actually be sent across the isolate boundary until | 42 /// No stream data will actually be sent across the isolate boundary until |
| 43 /// someone subscribes to the returned stream. | 43 /// someone subscribes to the returned stream. |
| 44 Stream deserializeStream(SendPort sendPort) { | 44 Stream deserializeStream(SendPort sendPort) { |
| 45 return callbackStream(() { | 45 return callbackStream(() { |
| 46 var receivePort = new ReceivePort(); | 46 var receivePort = new ReceivePort(); |
| 47 sendPort.send(receivePort.sendPort); | 47 sendPort.send(receivePort.sendPort); |
| 48 // TODO(nweiz): use a const constructor for StreamTransformer when issue |
| 49 // 14971 is fixed. |
| 48 return receivePort.transform( | 50 return receivePort.transform( |
| 49 const StreamTransformer(_deserializeTransformer)); | 51 new StreamTransformer(_deserializeTransformer)); |
| 50 }); | 52 }); |
| 51 } | 53 } |
| 52 | 54 |
| 53 /// The body of a [StreamTransformer] that deserializes the values in a stream | 55 /// The body of a [StreamTransformer] that deserializes the values in a stream |
| 54 /// sent by [serializeStream]. | 56 /// sent by [serializeStream]. |
| 55 StreamSubscription _deserializeTransformer(Stream input, bool cancelOnError) { | 57 StreamSubscription _deserializeTransformer(Stream input, bool cancelOnError) { |
| 56 var subscription; | 58 var subscription; |
| 57 var transformed = input.transform(new StreamTransformer.fromHandlers( | 59 var transformed = input.transform(new StreamTransformer.fromHandlers( |
| 58 handleData: (data, sink) { | 60 handleData: (data, sink) { |
| 59 if (data['type'] == 'data') { | 61 if (data['type'] == 'data') { |
| (...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 127 // short of a giant pile of type tests for each known exception type. | 129 // short of a giant pile of type tests for each known exception type. |
| 128 // | 130 // |
| 129 // So just try it. If it throws, default to toString(). | 131 // So just try it. If it throws, default to toString(). |
| 130 String _getErrorMessage(error) { | 132 String _getErrorMessage(error) { |
| 131 try { | 133 try { |
| 132 return error.message; | 134 return error.message; |
| 133 } on NoSuchMethodError catch (_) { | 135 } on NoSuchMethodError catch (_) { |
| 134 return error.toString(); | 136 return error.toString(); |
| 135 } | 137 } |
| 136 } | 138 } |
| OLD | NEW |