Dart: Reorganize files

mojo/dart/test/ping_pong_test.dart

-// Copyright 2014 The Chromium Authors. 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:isolate';
-import 'dart:typed_data';
-
-import 'package:mojo/core.dart' as core;
-
-ByteData byteDataOfString(String s) {
-  return new ByteData.view((new Uint8List.fromList(s.codeUnits)).buffer);
-}
-
-String stringOfByteData(ByteData bytes) {
-  return new String.fromCharCodes(bytes.buffer.asUint8List().toList());
-}
-
-void expectStringFromEndpoint(
-    String expected, core.MojoMessagePipeEndpoint endpoint) {
-  // Query how many bytes are available.
-  var result = endpoint.query();
-  assert(result != null);
-  int size = result.bytesRead;
-  assert(size > 0);
-
-  // Read the data.
-  ByteData bytes = new ByteData(size);
-  result = endpoint.read(bytes);
-  assert(result != null);
-  assert(size == result.bytesRead);
-
-  // Convert to a string and check.
-  String msg = stringOfByteData(bytes);
-  assert(expected == msg);
-}
-
-void pipeTestIsolate(core.MojoMessagePipeEndpoint endpoint) {
-  var eventSubscription = new core.MojoEventSubscription(endpoint.handle);
-  eventSubscription.subscribe((int mojoSignals) {
-    if (core.MojoHandleSignals.isReadWrite(mojoSignals)) {
-      throw 'We should only be reading or writing, not both.';
-    } else if (core.MojoHandleSignals.isReadable(mojoSignals)) {
-      expectStringFromEndpoint("Ping", endpoint);
-      eventSubscription.enableWriteEvents();
-    } else if (core.MojoHandleSignals.isWritable(mojoSignals)) {
-      endpoint.write(byteDataOfString("Pong"));
-      eventSubscription.enableReadEvents();
-    } else if (core.MojoHandleSignals.isPeerClosed(mojoSignals)) {
-      eventSubscription.close();
-    } else {
-      throw 'Unexpected event.';
-    }
-  });
-}
-
-main() {
-  var pipe = new core.MojoMessagePipe();
-  var endpoint = pipe.endpoints[0];
-  var eventSubscription = new core.MojoEventSubscription(endpoint.handle);
-  Isolate.spawn(pipeTestIsolate, pipe.endpoints[1]).then((_) {
-    eventSubscription.subscribe((int mojoSignals) {
-      if (core.MojoHandleSignals.isReadWrite(mojoSignals)) {
-        throw 'We should only be reading or writing, not both.';
-      } else if (core.MojoHandleSignals.isReadable(mojoSignals)) {
-        expectStringFromEndpoint("Pong", endpoint);
-        eventSubscription.close();
-      } else if (core.MojoHandleSignals.isWritable(mojoSignals)) {
-        endpoint.write(byteDataOfString("Ping"));
-        eventSubscription.enableReadEvents();
-      } else if (core.MojoHandleSignals.isPeerClosed(mojoSignals)) {
-        throw 'This end should close first.';
-      } else {
-        throw 'Unexpected event.';
-      }
-    });
-    eventSubscription.enableWriteEvents();
-  });
-}