[rxjs] Add Observable.expand (#1227)

This makes the `expand` method from the rxjs TypeScript sources visible in Flow as well.
duyitc · Sep 8, 2017 · 8787be9 · 8787be9
1 parent ce37a02
commit 8787be9
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/definitions/npm/rxjs_v5.0.x/flow_v0.25.0-v0.33.x/rxjs_v5.0.x.js b/definitions/npm/rxjs_v5.0.x/flow_v0.25.0-v0.33.x/rxjs_v5.0.x.js
@@ -152,6 +152,12 @@ declare class rxjs$Observable<+T> {
 
   elementAt(index: number, defaultValue?: T): rxjs$Observable<T>;
 
+  expand(
+    project: (value: T, index: number) => rxjs$Observable<T>,
+    concurrent?: number,
+    scheduler?: rxjs$SchedulerClass,
+  ): rxjs$Observable<T>;
+
   filter(predicate: (value: T, index: number) => boolean, thisArg?: any): rxjs$Observable<T>;
 
   finally(f: () => mixed): rxjs$Observable<T>;

diff --git a/definitions/npm/rxjs_v5.0.x/flow_v0.34.x-/rxjs_v5.0.x.js b/definitions/npm/rxjs_v5.0.x/flow_v0.34.x-/rxjs_v5.0.x.js
@@ -157,6 +157,12 @@ declare class rxjs$Observable<+T> {
 
   elementAt(index: number, defaultValue?: T): rxjs$Observable<T>;
 
+  expand(
+    project: (value: T, index: number) => rxjs$Observable<T>,
+    concurrent?: number,
+    scheduler?: rxjs$SchedulerClass,
+  ): rxjs$Observable<T>;
+
   filter(predicate: (value: T, index: number) => boolean, thisArg?: any): rxjs$Observable<T>;
 
   finally(f: () => mixed): rxjs$Observable<T>;

diff --git a/definitions/npm/rxjs_v5.0.x/test_rxjs.js b/definitions/npm/rxjs_v5.0.x/test_rxjs.js
@@ -195,3 +195,6 @@ numbers.filter(
   },
   {x: 'bar'}, // thisArg
 );
+
+Observable.of('a').expand(x => Observable.of(x + x)).subscribe(() => {});
+Observable.of(1).expand((x, i) => Observable.of(x + i)).subscribe(() => {});