| Index: tests/standalone/io/observatory_test.dart
|
| diff --git a/tests/standalone/io/observatory_test.dart b/tests/standalone/io/observatory_test.dart
|
| deleted file mode 100644
|
| index b9a656e3ca22d58b623d4ea0da7e6d7ca9df7d3b..0000000000000000000000000000000000000000
|
| --- a/tests/standalone/io/observatory_test.dart
|
| +++ /dev/null
|
| @@ -1,99 +0,0 @@
|
| -// Copyright (c) 2014, the Dart project authors. Please see the AUTHORS file
|
| -// for details. All rights reserved. Use of this source code is governed by a
|
| -// BSD-style license that can be found in the LICENSE file.
|
| -
|
| -import 'dart:async';
|
| -import 'dart:convert';
|
| -import 'dart:io';
|
| -import 'dart:mirrors';
|
| -
|
| -import 'package:expect/expect.dart';
|
| -import 'package:async_helper/async_helper.dart';
|
| -
|
| -Map lookupServiceObject(String path) {
|
| - var io = currentMirrorSystem().findLibrary(const Symbol('dart.io'));
|
| - var m = MirrorSystem.getSymbol('_serviceObjectHandler', io);
|
| - var paths = Uri.parse(path).pathSegments;
|
| - Expect.equals('io', paths.first);
|
| - return JSON.decode(
|
| - io.invoke(m, [paths.sublist(1), [], []]).reflectee);
|
| -}
|
| -
|
| -
|
| -String getServicePath(obj) {
|
| - var io = currentMirrorSystem().findLibrary(const Symbol('dart.io'));
|
| - var m = MirrorSystem.getSymbol('_getServicePath', io);
|
| - return io.invoke(m, [obj]).reflectee;
|
| -}
|
| -
|
| -
|
| -Future testHttpServer1() {
|
| - return HttpServer.bind('localhost', 0).then((server) {
|
| - var path = getServicePath(server);
|
| - var map = lookupServiceObject(path);
|
| - Expect.equals(map['type'], 'HttpServer');
|
| - Expect.equals(map['id'], path);
|
| - Expect.equals(map['address'], 'localhost');
|
| - Expect.equals(map['port'], server.port);
|
| - Expect.equals(map['closed'], false);
|
| - Expect.listEquals(map['idle'], []);
|
| - Expect.listEquals(map['active'], []);
|
| - var socket = map['socket'];
|
| - Expect.equals(socket['type'], '@Socket');
|
| - Expect.equals(socket['kind'], 'Listening');
|
| - // Validate owner back-ref.
|
| - socket = lookupServiceObject(socket['id']);
|
| - Expect.equals(socket['owner']['id'], path);
|
| - return server.close();
|
| - });
|
| -}
|
| -
|
| -
|
| -Future testHttpServerConnection1() {
|
| - return HttpServer.bind('localhost', 0).then((server) {
|
| - server.listen((request) {
|
| - var map = lookupServiceObject(getServicePath(server));
|
| - Expect.listEquals(map['idle'], []);
|
| - Expect.equals(map['active'].length, 1);
|
| - var active = map['active'].first;
|
| - Expect.equals(active['type'], '@HttpServerConnection');
|
| - var path = active['id'];
|
| - map = lookupServiceObject(path);
|
| - Expect.equals(map['type'], 'HttpServerConnection');
|
| - var socket = map['socket'];
|
| - Expect.equals(socket['type'], '@Socket');
|
| - Expect.equals(socket['kind'], 'Normal');
|
| - // Validate owner back-ref.
|
| - socket = lookupServiceObject(socket['id']);
|
| - Expect.equals(socket['owner']['id'], path);
|
| - request.response.close();
|
| - });
|
| - var client = new HttpClient();
|
| - return client.get('localhost', server.port, '/')
|
| - .then((request) => request.close())
|
| - .then((response) => response.drain())
|
| - .then((_) {
|
| - // The connection should be idle now.
|
| - var map = lookupServiceObject(getServicePath(server));
|
| - Expect.equals(map['idle'].length, 1);
|
| - Expect.listEquals(map['active'], []);
|
| - return server.close();
|
| - });
|
| -
|
| - });
|
| -}
|
| -
|
| -
|
| -void main() {
|
| - final tests = [
|
| - testHttpServer1(),
|
| - testHttpServerConnection1(),
|
| - ];
|
| -
|
| - asyncStart();
|
| - // Run one test at a time.
|
| - Future.forEach(tests, (f) => f)
|
| - .then((_) {
|
| - asyncEnd();
|
| - });
|
| -}
|
|
|