Skip to content

Commit c006da8

Browse files
authored
fix(compat/database): Zone should be destabilized on get (#2923)
1 parent 2788980 commit c006da8

File tree

3 files changed

+6
-6
lines changed

3 files changed

+6
-6
lines changed

src/compat/firestore/collection-group/collection-group.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ import { from, Observable } from 'rxjs';
22
import { fromCollectionRef } from '../observable/fromRef';
33
import { filter, map, scan } from 'rxjs/operators';
44
import firebase from 'firebase/compat/app';
5-
import { keepUnstableUntilFirst, observeInsideAngular } from '@angular/fire';
5+
import { keepUnstableUntilFirst } from '@angular/fire';
66

77
import { DocumentChangeAction, DocumentChangeType, DocumentData, Query } from '../interfaces';
88
import { validateEventsArray } from '../collection/collection';
@@ -108,7 +108,7 @@ export class AngularFirestoreCollectionGroup<T = DocumentData> {
108108
*/
109109
get(options?: firebase.firestore.GetOptions) {
110110
return from(this.query.get(options)).pipe(
111-
observeInsideAngular
111+
keepUnstableUntilFirst
112112
);
113113
}
114114

src/compat/firestore/collection/collection.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { from, Observable } from 'rxjs';
22
import { filter, map, pairwise, scan, startWith } from 'rxjs/operators';
33
import firebase from 'firebase/compat/app';
4-
import { keepUnstableUntilFirst, observeInsideAngular } from '@angular/fire';
4+
import { keepUnstableUntilFirst } from '@angular/fire';
55

66
import { CollectionReference, DocumentChangeAction, DocumentChangeType, DocumentData, DocumentReference, Query } from '../interfaces';
77
import { docChanges, sortedChanges } from './changes';
@@ -129,7 +129,7 @@ export class AngularFirestoreCollection<T = DocumentData> {
129129
*/
130130
get(options?: firebase.firestore.GetOptions) {
131131
return from(this.query.get(options)).pipe(
132-
observeInsideAngular,
132+
keepUnstableUntilFirst,
133133
);
134134
}
135135

src/compat/firestore/document/document.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ import { from, Observable } from 'rxjs';
22
import { keepUnstableUntilFirst } from '@angular/fire';
33
import { Action, DocumentData, DocumentReference, DocumentSnapshot, QueryFn, SetOptions } from '../interfaces';
44
import { fromDocRef } from '../observable/fromRef';
5-
import { map, observeOn } from 'rxjs/operators';
5+
import { map } from 'rxjs/operators';
66
import { AngularFirestore, associateQuery } from '../firestore';
77
import { AngularFirestoreCollection } from '../collection/collection';
88
import firebase from 'firebase/compat/app';
@@ -102,7 +102,7 @@ export class AngularFirestoreDocument<T = DocumentData> {
102102
*/
103103
get(options?: firebase.firestore.GetOptions) {
104104
return from(this.ref.get(options)).pipe(
105-
observeOn(this.afs.schedulers.insideAngular),
105+
keepUnstableUntilFirst,
106106
);
107107
}
108108
}

0 commit comments

Comments
 (0)