from(activities)
    .pipe(
        reduce((acc, { activity }) => {
             // return promise
            const result = library.execute( activity.payload );

            return from(result).pipe(
                 // как перехватить ошибку в этом месте
                catchError(e => throwError('example err'))
            );
        }, null),
         // а не в этом месте
        catchError(err => of(this.runCompensation(err))),
    )