@@ -24,7 +24,7 @@ const version = require('../../package.json').version;
24
24
class DeferredPromise < T > {
25
25
resolve : Function ;
26
26
reject : Function ;
27
- promise : Promise < T > ;
27
+ promise : Promise < T > | null ;
28
28
29
29
constructor ( ) {
30
30
this . resolve = ( ) => {
@@ -33,8 +33,7 @@ class DeferredPromise<T> {
33
33
this . reject = ( ) => {
34
34
throw new Error ( 'DeferredPromise.reject has not been initialized' ) ;
35
35
} ;
36
- this . promise =
37
- Promise . reject ( 'DeferredPromise.promise has not been initialized' ) ;
36
+ this . promise = null ;
38
37
}
39
38
}
40
39
@@ -666,8 +665,7 @@ describe('DocumentReference class', () => {
666
665
} ) ;
667
666
668
667
describe ( 'watch' , ( ) => {
669
- const currentDeferred = new DeferredPromise ( ) ;
670
-
668
+ const currentDeferred = new DeferredPromise < DocumentSnapshot > ( ) ;
671
669
672
670
function resetPromise ( ) {
673
671
currentDeferred . promise = new Promise ( ( resolve , reject ) => {
@@ -677,7 +675,7 @@ describe('DocumentReference class', () => {
677
675
}
678
676
679
677
function waitForSnapshot ( ) : Promise < DocumentSnapshot > {
680
- return currentDeferred . promise . then ( snapshot => {
678
+ return currentDeferred . promise ! . then ( snapshot => {
681
679
resetPromise ( ) ;
682
680
return snapshot as DocumentSnapshot ;
683
681
} ) ;
@@ -1187,7 +1185,7 @@ describe('Query class', () => {
1187
1185
}
1188
1186
1189
1187
function waitForSnapshot ( ) : Promise < QuerySnapshot > {
1190
- return currentDeferred . promise . then ( snapshot => {
1188
+ return currentDeferred . promise ! . then ( snapshot => {
1191
1189
resetPromise ( ) ;
1192
1190
return snapshot ;
1193
1191
} ) ;
0 commit comments