blob: 5f164a382c714d816d9dc5f3944e106f8ba92eba [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 event/callback protocol of the stream implementations.
library stream_state_test;
import "package:unittest/unittest.dart";
import "stream_state_helper.dart";
const ms5 = const Duration(milliseconds: 5);
main() {
mainTest(sync: true, asBroadcast: false);
mainTest(sync: true, asBroadcast: true);
mainTest(sync: false, asBroadcast: false);
mainTest(sync: false, asBroadcast: true);
}
void terminateWithDone(t, asBroadcast) {
if (asBroadcast) {
t
..expectCancel()
..expectDone()
..expectBroadcastCancel((_) => t.terminate());
} else {
t
..expectCancel()
..expectDone(t.terminate);
}
}
mainTest({bool sync, bool asBroadcast}) {
var p = (sync ? "S" : "AS") + (asBroadcast ? "BC" : "SC");
test("$p-sub-data-done", () {
var t = asBroadcast
? new StreamProtocolTest.asBroadcast(sync: sync)
: new StreamProtocolTest(sync: sync);
t
..expectListen()
..expectBroadcastListenOpt()
..expectData(42);
terminateWithDone(t, asBroadcast);
t
..listen()
..add(42)
..close();
});
test("$p-data-done-sub-sync", () {
var t = asBroadcast
? new StreamProtocolTest.asBroadcast(sync: sync)
: new StreamProtocolTest(sync: sync);
t
..expectListen()
..expectBroadcastListenOpt()
..expectData(42);
terminateWithDone(t, asBroadcast);
t
..add(42)
..close()
..listen();
});
test("$p-data-done-sub-async", () {
var t = asBroadcast
? new StreamProtocolTest.asBroadcast(sync: sync)
: new StreamProtocolTest(sync: sync);
t
..expectListen()
..expectBroadcastListenOpt()
..expectData(42);
terminateWithDone(t, asBroadcast);
t
..add(42)
..close()
..listen();
});
test("$p-sub-data/pause+resume-done", () {
var t = asBroadcast
? new StreamProtocolTest.asBroadcast(sync: sync)
: new StreamProtocolTest(sync: sync);
t
..expectListen()
..expectBroadcastListenOpt()
..expectData(42, () {
t.pause();
t.resume();
t.close();
});
terminateWithDone(t, asBroadcast);
t
..listen()
..add(42);
});
test("$p-sub-data-unsubonerror", () {
var t = asBroadcast
? new StreamProtocolTest.asBroadcast(sync: sync)
: new StreamProtocolTest(sync: sync);
if (asBroadcast) {
t
..expectListen()
..expectBroadcastListen()
..expectData(42)
..expectError("bad")
..expectBroadcastCancel()
..expectCancel(t.terminate);
} else {
t
..expectListen()
..expectData(42)
..expectCancel()
..expectError("bad", t.terminate);
}
t
..listen(cancelOnError: true)
..add(42)
..error("bad")
..add(43)
..close();
});
test("$p-sub-data-no-unsubonerror", () {
var t = asBroadcast
? new StreamProtocolTest.asBroadcast(sync: sync)
: new StreamProtocolTest(sync: sync);
t
..expectListen()
..expectBroadcastListenOpt()
..expectData(42)
..expectError("bad")
..expectData(43);
terminateWithDone(t, asBroadcast);
t
..listen(cancelOnError: false)
..add(42)
..error("bad")
..add(43)
..close();
});
test("$p-pause-resume-during-event", () {
var t = asBroadcast
? new StreamProtocolTest.broadcast(sync: sync)
: new StreamProtocolTest(sync: sync);
t
..expectListen()
..expectBroadcastListenOpt()
..expectData(42, () {
t.pause();
t.resume();
});
if (!asBroadcast && !sync) {
t..expectPause();
}
if (asBroadcast && sync) {
t
..expectDone()
..expectCancel(t.terminate);
} else {
t
..expectCancel()
..expectDone(t.terminate);
}
t
..listen()
..add(42)
..close();
});
test("$p-cancel-on-data", () {
var t = asBroadcast
? new StreamProtocolTest.asBroadcast(sync: sync)
: new StreamProtocolTest(sync: sync);
t
..expectListen()
..expectBroadcastListenOpt()
..expectData(42, t.cancel)
..expectBroadcastCancelOpt()
..expectCancel(t.terminate);
t
..listen(cancelOnError: false)
..add(42)
..close();
});
test("$p-cancel-on-error", () {
var t = asBroadcast
? new StreamProtocolTest.asBroadcast(sync: sync)
: new StreamProtocolTest(sync: sync);
t
..expectListen()
..expectBroadcastListenOpt()
..expectError(42, t.cancel)
..expectBroadcastCancelOpt()
..expectCancel(t.terminate);
t
..listen(cancelOnError: false)
..error(42)
..close();
});
}