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.

// @dart = 2.9

/// @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);
}