LibTest/async/Stream/distinct_A05_t01.test.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 Stream<T> distinct([bool equals(T previous, T next)])
///    Skips data events if they are equal to the previous data event.
///    The returned stream provides the same events as this stream, except that it
/// never provides two consecutive data events that are equal.
/// @description Checks that errors thrown by [equals] are added to the returned
/// stream.
/// @issue #29627
/// @author a.semenov@unipro.ru

library distinct_A05_t01;
import "../../../Utils/expect.dart";

void test(CreateStreamFunction create) {
  AsyncExpect.events([], [], create([]).distinct((p, n) => throw "error"));
  AsyncExpect.events([1], ["a","a"], create([1,2,3]).distinct((p, n) => throw "a"));
  AsyncExpect.events(
      [1,2,4], // data
      [3,5],  // errors
      create([1,2,3,4,5]).distinct((p, n) => n.isOdd ? throw n : p==n)
  );
}