// 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 events are not received if handler is set to null.
///
/// @author a.semenov@unipro.ru

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

Duration _500MS = new Duration(milliseconds: 500);

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

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

  void receiveHandler(event) {
    receivedData.add(event);
    if (receivedData.length == 5) {
      receivePort?.handler = null;
      // wait 500 ms for unexpected data
      new Future.delayed(_500MS).then((_) {
        receivePort?.close();
        Expect.listEquals(new List<int>.generate(5, (i) => i), receivedData);
        asyncEnd();
      });
    }
  }

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