feat(facade): add ObservableWrapper.fromPromise

vsavkin · vsavkin · commit 53bd6e1642d7 · 2015-11-02T18:03:02.000Z
diff --git a/modules/angular2/src/core/facade/async.dart b/modules/angular2/src/core/facade/async.dart
@@ -57,6 +57,10 @@ class ObservableWrapper {
   static void callComplete(EventEmitter emitter) {
     emitter.close();
   }
+
+  static Stream fromPromise(Future f) {
+    return new Stream.fromFuture(f);
+  }
 }
 
 class EventEmitter<T> extends Stream<T> {
diff --git a/modules/angular2/src/core/facade/async.ts b/modules/angular2/src/core/facade/async.ts
@@ -26,7 +26,7 @@ export class TimerWrapper {
 export class ObservableWrapper {
   // TODO(vsavkin): when we use rxnext, try inferring the generic type from the first arg
   static subscribe<T>(emitter: any, onNext: (value: T) => void, onError?: (exception: any) => void,
-                      onComplete?: () => void): Object {
+                      onComplete: () => void = () => {}): Object {
     return emitter.subscribe({next: onNext, error: onError, complete: onComplete});
   }
 
@@ -44,6 +44,10 @@ export class ObservableWrapper {
   static callError(emitter: EventEmitter<any>, error: any) { emitter.error(error); }
 
   static callComplete(emitter: EventEmitter<any>) { emitter.complete(); }
+
+  static fromPromise(promise: Promise<any>): Observable<any> {
+    return RxObservable.fromPromise(promise);
+  }
 }
 
 /**

Original file line number	Diff line number	Diff line change
`@@ -57,6 +57,10 @@ class ObservableWrapper {`
`57`	`57`	`static void callComplete(EventEmitter emitter) {`
`58`	`58`	`emitter.close();`
`59`	`59`	`}`
	`60`	`+`
	`61`	`+ static Stream fromPromise(Future f) {`
	`62`	`+ return new Stream.fromFuture(f);`
	`63`	`+ }`
`60`	`64`	`}`
`61`	`65`
`62`	`66`	`class EventEmitter<T> extends Stream<T> {`