2013-01-14 20:19:28 +00:00
|
|
|
library streams_test;
|
2014-04-09 19:42:11 +00:00
|
|
|
import 'package:unittest/unittest.dart';
|
|
|
|
import 'package:unittest/html_config.dart';
|
2013-01-14 20:19:28 +00:00
|
|
|
import 'dart:async';
|
|
|
|
import 'dart:html';
|
|
|
|
|
|
|
|
class StreamHelper {
|
|
|
|
var _a;
|
|
|
|
StreamHelper() {
|
|
|
|
_a = new TextInputElement();
|
|
|
|
document.body.append(_a);
|
|
|
|
}
|
|
|
|
|
2013-01-15 22:57:33 +00:00
|
|
|
Element get element => _a;
|
2013-01-14 20:19:28 +00:00
|
|
|
Stream<Event> get stream => _a.onFocus;
|
|
|
|
|
|
|
|
// Causes an event on a to be fired.
|
|
|
|
void pulse() {
|
2013-01-15 22:57:33 +00:00
|
|
|
var event = new Event('focus');
|
2013-01-24 19:42:02 +00:00
|
|
|
_a.dispatchEvent(event);
|
2013-01-14 20:19:28 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
main() {
|
|
|
|
useHtmlConfiguration();
|
|
|
|
|
|
|
|
test('simple', () {
|
2013-01-15 22:57:33 +00:00
|
|
|
var helper = new StreamHelper();
|
2013-01-14 20:19:28 +00:00
|
|
|
|
|
|
|
var callCount = 0;
|
2013-01-15 22:57:33 +00:00
|
|
|
helper.stream.listen((Event e) {
|
2013-01-14 20:19:28 +00:00
|
|
|
++callCount;
|
|
|
|
});
|
|
|
|
|
2013-01-15 22:57:33 +00:00
|
|
|
helper.pulse();
|
2013-01-14 20:19:28 +00:00
|
|
|
expect(callCount, 1);
|
|
|
|
});
|
|
|
|
|
2013-02-14 21:30:31 +00:00
|
|
|
test('broadcast', () {
|
|
|
|
var stream = new DivElement().onClick;
|
|
|
|
expect(stream.asBroadcastStream(), stream);
|
|
|
|
expect(stream.isBroadcast, isTrue);
|
|
|
|
});
|
|
|
|
|
2013-01-14 20:19:28 +00:00
|
|
|
// Validates that capturing events fire on parent before child.
|
|
|
|
test('capture', () {
|
|
|
|
var parent = new DivElement();
|
|
|
|
document.body.append(parent);
|
|
|
|
|
2013-01-15 22:57:33 +00:00
|
|
|
var helper = new StreamHelper();
|
|
|
|
parent.append(helper.element);
|
2013-01-14 20:19:28 +00:00
|
|
|
|
|
|
|
var childCallCount = 0;
|
|
|
|
var parentCallCount = 0;
|
|
|
|
Element.focusEvent.forTarget(parent, useCapture: true).listen((Event e) {
|
|
|
|
++parentCallCount;
|
|
|
|
expect(childCallCount, 0);
|
|
|
|
});
|
|
|
|
|
2013-01-15 22:57:33 +00:00
|
|
|
Element.focusEvent.forTarget(helper.element, useCapture: true).listen(
|
|
|
|
(Event e) {
|
|
|
|
++childCallCount;
|
|
|
|
expect(parentCallCount, 1);
|
|
|
|
});
|
2013-01-14 20:19:28 +00:00
|
|
|
|
2013-01-15 22:57:33 +00:00
|
|
|
helper.pulse();
|
2013-01-14 20:19:28 +00:00
|
|
|
expect(childCallCount, 1);
|
|
|
|
expect(parentCallCount, 1);
|
|
|
|
});
|
|
|
|
|
|
|
|
test('cancel', () {
|
|
|
|
var helper = new StreamHelper();
|
|
|
|
|
|
|
|
var callCount = 0;
|
|
|
|
var subscription = helper.stream.listen((_) {
|
|
|
|
++callCount;
|
|
|
|
});
|
|
|
|
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCount, 1);
|
|
|
|
|
|
|
|
subscription.cancel();
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCount, 1);
|
|
|
|
|
|
|
|
expect(() {
|
|
|
|
subscription.onData((_) {});
|
|
|
|
}, throws);
|
|
|
|
|
2013-04-03 14:14:32 +00:00
|
|
|
// Calling these after a cancel does nothing.
|
|
|
|
subscription.cancel();
|
|
|
|
subscription.pause();
|
|
|
|
subscription.resume();
|
2013-01-14 20:19:28 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
test('pause/resume', () {
|
|
|
|
var helper = new StreamHelper();
|
|
|
|
|
|
|
|
var callCount = 0;
|
|
|
|
var subscription = helper.stream.listen((_) {
|
|
|
|
++callCount;
|
|
|
|
});
|
|
|
|
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCount, 1);
|
|
|
|
|
|
|
|
subscription.pause();
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCount, 1);
|
|
|
|
|
|
|
|
subscription.resume();
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCount, 2);
|
|
|
|
|
2013-05-06 16:52:56 +00:00
|
|
|
var completer = new Completer<int>.sync();
|
2013-01-14 20:19:28 +00:00
|
|
|
subscription.pause(completer.future);
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCount, 2);
|
|
|
|
|
|
|
|
// Paused, should have no impact.
|
|
|
|
subscription.pause();
|
|
|
|
helper.pulse();
|
|
|
|
subscription.resume();
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCount, 2);
|
|
|
|
|
|
|
|
completer.complete(0);
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCount, 3);
|
|
|
|
|
2013-04-03 14:14:32 +00:00
|
|
|
// Not paused, but resuming once too often is ok.
|
|
|
|
subscription.resume();
|
2013-01-14 20:19:28 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
test('onData', () {
|
|
|
|
var helper = new StreamHelper();
|
|
|
|
|
|
|
|
var callCountOne = 0;
|
|
|
|
var subscription = helper.stream.listen((_) {
|
|
|
|
++callCountOne;
|
|
|
|
});
|
|
|
|
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCountOne, 1);
|
|
|
|
|
|
|
|
var callCountTwo = 0;
|
|
|
|
subscription.onData((_) {
|
|
|
|
++callCountTwo;
|
|
|
|
});
|
|
|
|
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCountOne, 1);
|
|
|
|
expect(callCountTwo, 1);
|
|
|
|
});
|
|
|
|
|
|
|
|
test('null onData', () {
|
|
|
|
var helper = new StreamHelper();
|
|
|
|
|
|
|
|
var subscription = helper.stream.listen(null);
|
|
|
|
helper.pulse();
|
|
|
|
|
|
|
|
var callCountOne = 0;
|
|
|
|
subscription.onData((_) {
|
|
|
|
++callCountOne;
|
|
|
|
});
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCountOne, 1);
|
|
|
|
|
|
|
|
subscription.onData(null);
|
|
|
|
helper.pulse();
|
|
|
|
expect(callCountOne, 1);
|
|
|
|
});
|
2013-01-28 16:58:31 +00:00
|
|
|
|
|
|
|
var stream = new StreamHelper().stream;
|
|
|
|
// Streams have had some type-checking issues, these tests just validate that
|
|
|
|
// those are OK.
|
|
|
|
test('first', () {
|
|
|
|
stream.first.then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('asBroadcastStream', () {
|
|
|
|
stream.asBroadcastStream().listen((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('where', () {
|
|
|
|
stream.where((_) => true).listen((_) {});
|
|
|
|
});
|
|
|
|
|
2013-02-18 10:35:51 +00:00
|
|
|
test('map', () {
|
2013-01-31 15:12:56 +00:00
|
|
|
stream.map((_) => null).listen((_) {});
|
2013-01-28 16:58:31 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
test('reduce', () {
|
2013-04-11 08:32:31 +00:00
|
|
|
stream.reduce((a, b) => null).then((_) {});
|
2013-01-28 16:58:31 +00:00
|
|
|
});
|
|
|
|
|
2013-04-05 16:12:40 +00:00
|
|
|
test('fold', () {
|
|
|
|
stream.fold(null, (a, b) => null).then((_) {});
|
|
|
|
});
|
|
|
|
|
2013-01-28 16:58:31 +00:00
|
|
|
test('contains', () {
|
|
|
|
stream.contains((_) => true).then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('every', () {
|
|
|
|
stream.every((_) => true).then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('any', () {
|
|
|
|
stream.any((_) => true).then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('length', () {
|
|
|
|
stream.length.then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('isEmpty', () {
|
|
|
|
stream.isEmpty.then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('toList', () {
|
|
|
|
stream.toList().then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('toSet', () {
|
|
|
|
stream.toSet().then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('take', () {
|
|
|
|
stream.take(1).listen((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('takeWhile', () {
|
|
|
|
stream.takeWhile((_) => false).listen((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('skip', () {
|
|
|
|
stream.skip(0).listen((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('skipWhile', () {
|
|
|
|
stream.skipWhile((_) => false).listen((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('distinct', () {
|
|
|
|
stream.distinct((a, b) => false).listen((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('first', () {
|
|
|
|
stream.first.then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('last', () {
|
|
|
|
stream.last.then((_) {});
|
|
|
|
});
|
|
|
|
|
|
|
|
test('single', () {
|
|
|
|
stream.single.then((_) {});
|
|
|
|
});
|
|
|
|
|
2013-03-12 17:34:49 +00:00
|
|
|
test('firstWhere', () {
|
|
|
|
stream.firstWhere((_) => true).then((_) {});
|
2013-01-28 16:58:31 +00:00
|
|
|
});
|
|
|
|
|
2013-03-12 17:34:49 +00:00
|
|
|
test('lastWhere', () {
|
|
|
|
stream.lastWhere((_) => true).then((_) {});
|
2013-01-28 16:58:31 +00:00
|
|
|
});
|
|
|
|
|
2013-03-12 17:34:49 +00:00
|
|
|
test('singleWhere', () {
|
|
|
|
stream.singleWhere((_) => true).then((_) {});
|
2013-01-28 16:58:31 +00:00
|
|
|
});
|
|
|
|
|
|
|
|
test('elementAt', () {
|
|
|
|
stream.elementAt(0).then((_) {});
|
|
|
|
});
|
2013-01-14 20:19:28 +00:00
|
|
|
}
|