sdk/tests/isolate/src/NestedSpawn2Test.dart

// Copyright (c) 2011, 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.

// Dart test program for testing that isolates can spawn other isolates and
// that the nested isolates can communicate with the main once the spawner has
// disappeared.

#library('NestedSpawn2Test');
#import('TestFramework.dart');

class IsolateA extends Isolate {
  IsolateA() : super.heavy();

  void main() {
    this.port.receive((msg, replyTo) {
      Expect.equals("launch nested!", msg);
      new IsolateB().spawn().then((SendPort p) {
        p.send(replyTo, null);
        this.port.close();
      });
    });
  }
}

String msg0 = "0 there?";
String msg1 = "1 Yes.";
String msg2 = "2 great. Think the other one is already dead?";
String msg3 = "3 Give him some time.";
String msg4 = "4 now?";
String msg5 = "5 Now.";
String msg6 = "6 Great. Bye";

class IsolateB extends Isolate {
  IsolateB() : super.heavy();

  void main() {
    this.port.receive((mainPort, replyTo) {
      this.port.close();
      // Do a little ping-pong dance to give the intermediate isolate time to
      // die.
      mainPort.call(msg0).receive((msg, replyTo) {
        Expect.equals("1", msg[0]);
        replyTo.call(msg2).receive((msg, replyTo) {
              Expect.equals("3", msg[0]);
              replyTo.call(msg4).receive((msg, replyTo) {
                Expect.equals("5", msg[0]);
                replyTo.send(msg6, null);
              });
            });
      });
    });
  }
}

test(TestExpectation expect) {
  expect.completes(new IsolateA().spawn()).then((SendPort port) {
    port.call("launch nested!").receive(expect.runs2((msg, replyTo) {
      Expect.equals("0", msg[0]);
      replyTo.call(msg1).receive(expect.runs2((msg, replyTo) {
        Expect.equals("2", msg[0]);
        replyTo.call(msg3).receive(expect.runs2((msg, replyTo) {
              Expect.equals("4", msg[0]);
              replyTo.call(msg5).receive(expect.runs2((msg, replyTo) {
                Expect.equals("6", msg[0]);
                expect.succeeded();
              }));
            }));
      }));
    }));
  });
}

main() {
  runTests([test]);
}