blob: 595f289bc2cf140c876a9d2e5fe7149c57a06d8c [file] [log] [blame]
// Copyright (c) 2013, 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.
// Test the Stream.single method.
library stream_single_test;
import "package:expect/expect.dart";
import 'dart:async';
import 'package:unittest/unittest.dart';
main() {
test("subscription.asFuture success", () {
Stream stream = new Stream.fromIterable([1, 2, 3]);
var output = [];
var subscription = stream.listen((x) {
output.add(x);
});
subscription.asFuture(output).then(expectAsync((o) {
Expect.listEquals([1, 2, 3], o);
}));
});
test("subscription.asFuture success2", () {
StreamController controller = new StreamController(sync: true);
[1, 2, 3].forEach(controller.add);
controller.close();
Stream stream = controller.stream;
var output = [];
var subscription = stream.listen((x) {
output.add(x);
});
subscription.asFuture(output).then(expectAsync((o) {
Expect.listEquals([1, 2, 3], o);
}));
});
test("subscription.asFuture success 3", () {
Stream stream = new Stream.fromIterable([1, 2, 3]).map((x) => x);
var output = [];
var subscription = stream.listen((x) {
output.add(x);
});
subscription.asFuture(output).then(expectAsync((o) {
Expect.listEquals([1, 2, 3], o);
}));
});
test("subscription.asFuture different type", () {
Stream stream = new Stream<int>.fromIterable([1, 2, 3]);
var asyncCallback = expectAsync(() => {});
var output = [];
var subscription = stream.listen((x) {
output.add(x);
});
subscription.asFuture("string").then((String o) {
Expect.listEquals([1, 2, 3], output);
Expect.equals("string", o);
asyncCallback();
});
});
test("subscription.asFuture failure", () {
StreamController controller = new StreamController(sync: true);
[1, 2, 3].forEach(controller.add);
controller.addError("foo");
controller.close();
Stream stream = controller.stream;
var output = [];
var subscription = stream.listen((x) {
output.add(x);
});
subscription.asFuture(output).catchError(expectAsync((error) {
Expect.equals(error, "foo");
}));
});
test("subscription.asFuture failure2", () {
Stream stream = new Stream.fromIterable([1, 2, 3, 4]).map((x) {
if (x == 4) throw "foo";
return x;
});
var output = [];
var subscription = stream.listen((x) {
output.add(x);
});
subscription.asFuture(output).catchError(expectAsync((error) {
Expect.equals(error, "foo");
}));
});
test("subscription.asFuture delayed cancel", () {
var completer = new Completer();
var controller =
new StreamController(onCancel: () => completer.future, sync: true);
[1, 2, 3].forEach(controller.add);
controller.addError("foo");
controller.close();
Stream stream = controller.stream;
var output = [];
var subscription = stream.listen((x) {
output.add(x);
});
bool catchErrorHasRun = false;
subscription.asFuture(output).catchError(expectAsync((error) {
Expect.equals(error, "foo");
catchErrorHasRun = true;
}));
Timer.run(expectAsync(() {
Expect.isFalse(catchErrorHasRun);
completer.complete();
}));
});
test("subscription.asFuture failure in cancel", () {
runZoned(() {
var completer = new Completer();
var controller =
new StreamController(onCancel: () => completer.future, sync: true);
[1, 2, 3].forEach(controller.add);
controller.addError("foo");
controller.close();
Stream stream = controller.stream;
var output = [];
var subscription = stream.listen((x) {
output.add(x);
});
bool catchErrorHasRun = false;
subscription.asFuture(output).catchError(expectAsync((error) {
Expect.equals(error, "foo");
catchErrorHasRun = true;
}));
Timer.run(expectAsync(() {
Expect.isFalse(catchErrorHasRun);
completer.completeError(499);
}));
}, onError: expectAsync((e) {
Expect.equals(499, e);
}));
});
}