Method asObservable

packages/core/src/lib/selection.ts:28–44

()

  }

  asObservable(): Observable<T | undefined> {
    if (this.unit.config.immutable === true) {
      // allows to optimize cases when the whole value is not new,
      // e.g.: updating property 'a' in a DictUnit using 'set',
      // wouldn't trigger paths that start with property 'b'
      return this.unit.pipe(
        map(() => plucker(this.unit.rawValue(), this.path)),
        distinctUntilChanged(),
        map(() => plucker((this.unit as any).emittedValue, this.path))
      );
    }

    return this.unit.pipe(
      map(value => plucker(value, this.path)),
      distinctUntilChanged()
    );
  }
}