diff --git a/modules/angular2/src/core/facade/async.dart b/modules/angular2/src/core/facade/async.dart index c454330e358..6ffa49ab045 100644 --- a/modules/angular2/src/core/facade/async.dart +++ b/modules/angular2/src/core/facade/async.dart @@ -61,6 +61,10 @@ class ObservableWrapper { static Stream fromPromise(Future f) { return new Stream.fromFuture(f); } + + static Future toPromise(Stream s) { + return s.single; + } } class EventEmitter extends Stream { diff --git a/modules/angular2/src/core/facade/async.ts b/modules/angular2/src/core/facade/async.ts index 33f039dfb3d..249f30b19f3 100644 --- a/modules/angular2/src/core/facade/async.ts +++ b/modules/angular2/src/core/facade/async.ts @@ -48,6 +48,8 @@ export class ObservableWrapper { static fromPromise(promise: Promise): Observable { return RxObservable.fromPromise(promise); } + + static toPromise(obj: Observable): Promise { return (obj).toPromise(); } } /**