blob: 5f8006537fdc49dd788f7baf2b05705ad045c247 [file] [log] [blame]
// Copyright (c) 2012, 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.
library test;
import 'package:expect/expect.dart';
import 'dart:isolate';
import "package:async_helper/async_helper.dart";
funcFoo(x) => x + 2;
foo() {
stream.single.then((msg) {
IsolateSink sink = msg;
sink.add(499);
sink.close();
});
}
main() {
var box = new MessageBox();
var snd = streamSpawnFunction(foo);
var caught_exception = false;
try {
snd.add(funcFoo);
} catch (e) {
caught_exception = true;
}
snd.add(box.sink);
snd.close();
asyncStart();
box.stream.single.then((msg) {
Expect.equals(499, msg);
asyncEnd();
});
}