Function commit

packages/angular_devkit/schematics/src/sink/sink.ts:149–175

(tree: Tree)

  }

  commit(tree: Tree): Observable<void> {
    const actions = observableFrom(tree.actions);

    return concat(
      this.preCommit() || observableOf(null),
      deferObservable(() => actions).pipe(
        concatMap((action) => {
          const maybeAction = this.preCommitAction(action);

          if (isObservable(maybeAction) || isPromiseLike(maybeAction)) {
            return maybeAction;
          }

          return observableOf(maybeAction || action);
        }),
        concatMap((action) => {
          return concat(
            this.commitSingleAction(action).pipe(ignoreElements()),
            observableOf(action),
          );
        }),
        concatMap((action) => this.postCommitAction(action) || observableOf(null)),
      ),
      deferObservable(() => this._done()),
      deferObservable(() => this.postCommit() || observableOf(null)),
    ).pipe(ignoreElements(), defaultIfEmpty(undefined));
  }
}

function isPromiseLike<T, U = unknown>(value: U | PromiseLike<T>): value is PromiseLike<T> {