Future checkDistant()

in LibTest/io/RawDatagramSocket/distinct_A02_t01.dart [24:72]

• 46 lines of code
• 4 McCabe index (conditional complexity)

Future<List> checkDistant() async {
  RawDatagramSocket producer = await RawDatagramSocket.bind(localhost, 0);
  RawDatagramSocket receiver = await RawDatagramSocket.bind(localhost, 0);
  List<List<int>> toSend = [[0, 1, 2, 3], [1, 2, 3], [2, 3], [3], [4, 5], [5]];
  List<RawSocketEvent> received1 = [];
  List<RawSocketEvent> received2 = [];
  List<RawSocketEvent> received3 = [];
  List<int> received = [0, 0, 0, 0];
  Completer<List<int>> completer = new Completer<List<int>>();
  Future<List<int>> f = completer.future;
  Duration delay = const Duration(seconds: 2);

  bool wasSent = await sendDatagram(producer, toSend, localhost, receiver.port);
  Expect.isTrue(wasSent, "No datagram was sent");

  Stream bcs = receiver.asBroadcastStream();
  Expect.isTrue(bcs.isBroadcast);
  Stream s = bcs.distinct((previous, next) => previous == next);
  Expect.isTrue(s.isBroadcast);
  s.listen((event) {
    received1.add(event);
  });
  s.listen((event) {
    received2.add(event);
  });
  s.listen((event) {
    received3.add(event);
  });
  bcs.listen((event) {
    receiver.receive();
    received[0]++;
    if (event == RawSocketEvent.closed) {
      if (!completer.isCompleted) {
        completer.complete(received);
      }
    }
  }, onDone: () {
    received[1] = received1.length;
    received[2] = received2.length;
    received[3] = received3.length;
  });

  new Future.delayed(delay, () {
    if (!completer.isCompleted) {
      receiver.close();
    }
  });
  return f;
}