| Index: dart/sdk/lib/async/stream.dart
|
| diff --git a/dart/sdk/lib/async/stream.dart b/dart/sdk/lib/async/stream.dart
|
| index ffa10233ca043a6f3d0658816d3b15c251e44d4c..68e2588bbab43e4717b253c5116992817a0e4ed8 100644
|
| --- a/dart/sdk/lib/async/stream.dart
|
| +++ b/dart/sdk/lib/async/stream.dart
|
| @@ -30,7 +30,9 @@ abstract class Stream<T> {
|
| * The merged streams are paused and resumed in order to ensure the proper
|
| * order of output events.
|
| */
|
| - factory Stream.cyclic(Iterable<Stream> sources) = CyclicScheduleStream<T>;
|
| + factory Stream.cyclic(Iterable<Stream> sources) {
|
| + return new CyclicScheduleStream<T>(sources);
|
| + }
|
|
|
| /**
|
| * Create a stream that forwards data from the highest priority active source.
|
| @@ -45,7 +47,9 @@ abstract class Stream<T> {
|
| * If a higher priority source stream completes without providing data,
|
| * it will have no effect on lower priority streams.
|
| */
|
| - factory Stream.superceding(Iterable<Stream<T>> sources) = SupercedeStream<T>;
|
| + factory Stream.superceding(Iterable<Stream<T>> sources) {
|
| + return new SupercedeStream<T>(sources);
|
| + }
|
|
|
| /**
|
| * Add a subscription to this stream.
|
|
|