map-operators-edit-one-01.ts

export class BookEffects {
  @Effect() updateBook$ = this.actions$.pipe(
    ofType(INPUT_ACTION_TYPE),
    groupBy(
      action => action.bookId,
      action => action,
      action$ => action$.pipe(
        timeoutWith(15000, Observable.empty()),
        ignoreElements(),
      ),
    ),
    map(action$ => action$.pipe(
      concatMap(action => this.bookService.updateOne(
        action.bookId,
        action.bookUpdates,
      )),
    ),
    mergeAll(),
  );
}