Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1)

Unified Diff: packages/barback/lib/src/serialize.dart

Issue 3015713002: Roll to pickup pool changes
Patch Set: Created 3 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: packages/barback/lib/src/serialize.dart
diff --git a/packages/barback/lib/src/serialize.dart b/packages/barback/lib/src/serialize.dart
index 10cc6fe06e30c431f0f310cf7ed6b01ae3115e06..c2f7ac4a1ca47adf865e06c57a0a4681aeaa344c 100644
--- a/packages/barback/lib/src/serialize.dart
+++ b/packages/barback/lib/src/serialize.dart
@@ -23,11 +23,11 @@ SendPort serializeStream(Stream stream) {
stream.listen((data) => sendPort.send({'type': 'data', 'data': data}),
onDone: () => sendPort.send({'type': 'done'}),
onError: (error, stackTrace) {
- sendPort.send({
- 'type': 'error',
- 'error': CrossIsolateException.serialize(error, stackTrace)
- });
- });
+ sendPort.send({
+ 'type': 'error',
+ 'error': CrossIsolateException.serialize(error, stackTrace)
+ });
+ });
});
return receivePort.sendPort;
@@ -45,8 +45,8 @@ Stream deserializeStream(SendPort sendPort) {
return callbackStream(() {
var receivePort = new ReceivePort();
sendPort.send(receivePort.sendPort);
- return receivePort.transform(
- const StreamTransformer(_deserializeTransformer));
+ return receivePort
+ .transform(const StreamTransformer(_deserializeTransformer));
});
}
@@ -54,8 +54,8 @@ Stream deserializeStream(SendPort sendPort) {
/// sent by [serializeStream].
StreamSubscription _deserializeTransformer(Stream input, bool cancelOnError) {
var subscription;
- var transformed = input.transform(new StreamTransformer.fromHandlers(
- handleData: (data, sink) {
+ var transformed = input
+ .transform(new StreamTransformer.fromHandlers(handleData: (data, sink) {
if (data['type'] == 'data') {
sink.add(data['data']);
} else if (data['type'] == 'error') {
@@ -95,8 +95,8 @@ class CrossIsolateException implements Exception {
CrossIsolateException.deserialize(Map error)
: type = error['type'],
message = error['message'],
- stackTrace = error['stack'] == null ? null :
- new Chain.parse(error['stack']);
+ stackTrace =
+ error['stack'] == null ? null : new Chain.parse(error['stack']);
/// Serializes [error] to an object that can safely be passed across isolate
/// boundaries.

Powered by Google App Engine
This is Rietveld 408576698