+ .catch(err => next(err))
+ }
+}
+
+function asyncRetryTransactionMiddleware (fun: (req: Request, res: Response, next: NextFunction) => Promise<any>) {
+ return (req: Request, res: Response, next: NextFunction) => {
+ return Promise.resolve(
+ retryTransactionWrapper(fun, req, res, next)
+ ).catch(err => next(err))