Function valueChanges

src/compat/database/list/create-reference.ts:31–48

(events?: ChildEvent[], options?: {idField?: K})

      return auditTrail<T>(query, events, outsideAngularScheduler).pipe(pendingUntilEvent(injector));
    },
    valueChanges<K extends string>(events?: ChildEvent[], options?: {idField?: K}): Observable<(T & Record<string, string>)[]> {
      const snapshotChanges$ = snapshotChanges<T>(query, events, outsideAngularScheduler);
      return snapshotChanges$.pipe(
        map(actions => actions.map(a => {
          if (options && options.idField) {
            return {
              ...a.payload.val() as T,
              ...{
                [options.idField]: a.key
              }
            };
          } else {
            return a.payload.val() as T & Record<string, string>
          }
        })),
        pendingUntilEvent(injector)
      );
    }
  };
}