Function valueChanges

src/compat/database/object/create-reference.ts:19–25

()

    set(data: T) { return query.ref.set(data) as Promise<void>; },
    remove() { return query.ref.remove() as Promise<void>; },
    valueChanges<T>() {
      const snapshotChanges$ = createObjectSnapshotChanges(query, afDatabase.schedulers.outsideAngular)();
      return snapshotChanges$.pipe(
        pendingUntilEvent(injector),
        map(action => action.payload.exists() ? action.payload.val() as T : null)
      );
    },
  };
}