Function fromDocRef

src/compat/firestore/observable/fromRef.ts:28–44

(ref: DocumentReference<T>, scheduler?: SchedulerLike)

}

export function fromDocRef<T>(ref: DocumentReference<T>, scheduler?: SchedulerLike): Observable<Action<DocumentSnapshot<T>>> {
  return fromRef<DocumentSnapshot<T>, T>(ref, scheduler)
    .pipe(
      startWith<DocumentSnapshot<T>, undefined>(undefined),
      pairwise(),
      map((snapshots: [DocumentSnapshot<T>, DocumentSnapshot<T>]) => {
        const [priorPayload, payload] = snapshots;
        if (!payload.exists) {
          return { payload, type: 'removed' };
        }
        if (!priorPayload?.exists) {
          return { payload, type: 'added' };
        }
        return { payload, type: 'modified' };
      })
    );
}

export function fromCollectionRef<T>(ref: Query<T>, scheduler?: SchedulerLike): Observable<Action<QuerySnapshot<T>>> {
  return fromRef<QuerySnapshot<T>, T>(ref, scheduler).pipe(map(payload => ({ payload, type: 'query' })));