Index: runtime/observatory/tests/service/tcp_socket_closing_service_test.dart |
diff --git a/runtime/observatory/tests/service/tcp_socket_closing_service_test.dart b/runtime/observatory/tests/service/tcp_socket_closing_service_test.dart |
index 38e415b65277f2935400698d699261aa87b3b5fa..fa07ced4e0653e7d16dc51eb36a33319030a7ad0 100644 |
--- a/runtime/observatory/tests/service/tcp_socket_closing_service_test.dart |
+++ b/runtime/observatory/tests/service/tcp_socket_closing_service_test.dart |
@@ -9,7 +9,6 @@ import 'package:observatory/service_io.dart'; |
import 'package:unittest/unittest.dart'; |
import 'test_helper.dart'; |
- |
/// Test that we correctly remove sockets that have been closed from the list |
/// of open sockets. We explictly leave one socket open. |
@@ -36,7 +35,7 @@ Future setup() async { |
var server = await io.RawDatagramSocket.bind('127.0.0.1', 0); |
server.listen((io.RawSocketEvent event) { |
- if(event == io.RawSocketEvent.READ) { |
+ if (event == io.RawSocketEvent.READ) { |
io.Datagram dg = server.receive(); |
dg.data.forEach((x) => true); |
server.close(); |
@@ -44,7 +43,7 @@ Future setup() async { |
}); |
var client = await io.RawDatagramSocket.bind('127.0.0.1', 0); |
client.send(UTF8.encoder.convert('foobar'), |
- new io.InternetAddress('127.0.0.1'), server.port); |
+ new io.InternetAddress('127.0.0.1'), server.port); |
client.close(); |
// The one socket to expect. |
@@ -61,7 +60,7 @@ var tests = [ |
// end of test. |
expect(result['data'].length, equals(1)); |
var server = await isolate.invokeRpcNoUpgrade( |
- 'ext.dart.io.getSocketByID', { 'id' : result['data'][0]['id'] }); |
+ 'ext.dart.io.getSocketByID', {'id': result['data'][0]['id']}); |
expect(server['listening'], isTrue); |
expect(server['lastRead'], equals(0)); |
expect(server['totalRead'], equals(0)); |
@@ -72,4 +71,4 @@ var tests = [ |
}, |
]; |
-main(args) async => runIsolateTests(args, tests, testeeBefore:setup); |
+main(args) async => runIsolateTests(args, tests, testeeBefore: setup); |