diff --git a/packages/flutter_tools/lib/src/test/flutter_platform.dart b/packages/flutter_tools/lib/src/test/flutter_platform.dart index d3e6ecbd7e..28b167153e 100644 --- a/packages/flutter_tools/lib/src/test/flutter_platform.dart +++ b/packages/flutter_tools/lib/src/test/flutter_platform.dart @@ -72,11 +72,11 @@ void _attachStandardStreams(Process process) { class FlutterPlatform extends PlatformPlugin { @override - StreamChannel loadChannel(String mainPath, TestPlatform platform) { + StreamChannel loadChannel(String mainPath, TestPlatform platform) { return StreamChannelCompleter.fromFuture(_startTest(mainPath)); } - Future> _startTest(String mainPath) async { + Future> _startTest(String mainPath) async { _ServerInfo info = await _startServer(); Directory tempDir = Directory.systemTemp.createTempSync( 'dart_test_listener'); @@ -126,16 +126,16 @@ void main() { try { WebSocket socket = await info.socket; - StreamChannel channel = new StreamChannel(socket.map(JSON.decode), socket); + StreamChannel channel = new StreamChannel(socket.map(JSON.decode), socket); return channel.transformStream( - new StreamTransformer.fromHandlers( - handleDone: (EventSink sink) { + new StreamTransformer.fromHandlers( + handleDone: (EventSink sink) { finalize(); sink.close(); } ) - ).transformSink(new StreamSinkTransformer.fromHandlers( - handleData: (String data, StreamSink sink) { + ).transformSink(new StreamSinkTransformer.fromHandlers( + handleData: (dynamic data, StreamSink sink) { sink.add(JSON.encode(data)); }, handleDone: (EventSink sink) {