LibTest/async/Stream/reduce_A02_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 Future<T> reduce(T combine(T previous, T element))
/// Reduces a sequence of values by repeatedly applying combine.
/// @description Checks that if [combine] throws error, then returned future is
/// completed with this error.
/// @author a.semenov@unipro.ru

library reduce_A02_t01;

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

void test(CreateStreamFunction create) {
  AsyncExpect.error("a", create([1, 2, 3]).reduce((p, e) => throw "a"));
  AsyncExpect.error(2, create([1, 2, 3]).reduce((p, e) => throw e));
  AsyncExpect.error(
      3,
      create([1, 2, 3, 4, 5]).reduce((p, e) {
        if (e == 3) throw e;
        return p + e;
      }));
}