fix(bluebird): fix #1112, bluebird chained callback should return a Bluebird Promise

Author: JiaLiPassion

lib/common/promise.ts

@@ -476,11 +476,6 @@ Zone.__load_patch('ZoneAwarePromise', (global: any, Zone: ZoneType, api: _ZonePr
 
   if (NativePromise) {
     patchThen(NativePromise);
-
-    /*let fetch = global['fetch'];
-    if (typeof fetch == 'function') {
-      global['fetch'] = zoneify(fetch);
-    }*/
   }
 
   // This is not part of public API, but it is useful for tests, so we expose it.

lib/extra/bluebird.ts

@@ -25,8 +25,14 @@ Zone.__load_patch('bluebird', (global: any, Zone: ZoneType, api: _ZonePrivate) =
                 args[i] = function() {
                   const argSelf: any = this;
                   const argArgs: any = arguments;
-                  zone.scheduleMicroTask('Promise.then', () => {
-                    return func.apply(argSelf, argArgs);
+                  return new Bluebird((res: any, rej: any) => {
+                    zone.scheduleMicroTask('Promise.then', () => {
+                      try {
+                        res(func.apply(argSelf, argArgs));
+                      } catch (error) {
+                        rej(error);
+                      }
+                    });
                   });
                 };
               }

test/extra/bluebird.spec.ts

@@ -9,6 +9,10 @@
 // this spec will not be integrated with Travis CI, because I don't
 // want to add bluebird into devDependencies, you can run this spec
 // on your local environment
+process.on('unhandledRejection', (reason, p) => {
+  console.log('Unhandled Rejection at:', p, 'reason:', reason);
+  // application specific logging, throwing an error, or other logic here
+});
 
 describe('bluebird promise', () => {
   let BluebirdPromise: any;
@@ -636,4 +640,42 @@ describe('bluebird promise', () => {
       });
     });
   });
+
+  it('should be able to chain promise', (done: DoneFn) => {
+    Zone.current.fork({name: 'zone_A'}).run(() => {
+      new BluebirdPromise((resolve: any, reject: any) => {
+        expect(Zone.current.name).toEqual('zone_A');
+        resolve(1);
+      })
+          .then((r: any) => {
+            expect(r).toBe(1);
+            expect(Zone.current.name).toEqual('zone_A');
+            return Promise.resolve(2);
+          })
+          .then((r: any) => {
+            expect(r).toBe(2);
+            expect(Zone.current.name).toEqual('zone_A');
+          });
+    });
+    Zone.current.fork({name: 'zone_B'}).run(() => {
+      new BluebirdPromise((resolve: any, reject: any) => {
+        expect(Zone.current.name).toEqual('zone_B');
+        reject(1);
+      })
+          .then(
+              () => {
+                fail('should not be here.');
+              },
+              (r: any) => {
+                expect(r).toBe(1);
+                expect(Zone.current.name).toEqual('zone_B');
+                return Promise.resolve(2);
+              })
+          .then((r: any) => {
+            expect(r).toBe(2);
+            expect(Zone.current.name).toEqual('zone_B');
+            done();
+          });
+    });
+  });
 });