LibTest/isolate/RawReceivePort/handler_A03_t01.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.
 */
/**
 * @assertion void set handler=(Function newHandler)
 * Sets the handler that is invoked for every incoming message.
 * The handler is invoked in the root-zone (Zone.root).
 *
 * @description Checks that different handlers can be used sequentially
 *
 * @author a.semenov@unipro.ru
 */

import "dart:isolate";
import "../../../Utils/expect.dart";

void entryPoint(SendPort sendPort) {
  for (int i = 0; i < 100; i++) {
    sendPort.send(i);
  }
}

typedef void Handler(event);

main() {
  asyncStart();
  RawReceivePort? receivePort;
  List receivedData1 = [];
  List receivedData2 = [];

  void check() {
    if (receivedData1.length == 50 && receivedData2.length == 50) {
      receivePort?.close();
      Expect.listEquals(
          new List<int>.generate(50, (i) => i * 2), receivedData1);
      Expect.listEquals(
          new List<int>.generate(50, (i) => i * 2 + 1), receivedData2);
      asyncEnd();
    }
  }

  Handler? handler1;
  Handler handler2 = (event) {
    receivedData2.add(event);
    receivePort?.handler = handler1;
    check();
  };
  handler1 = (event) {
    receivedData1.add(event);
    receivePort?.handler = handler2;
    check();
  };

  receivePort = new RawReceivePort(handler1);
  Isolate.spawn(entryPoint, receivePort.sendPort);
}