Skip to content

Commit eca2b0e

Browse files
committed
fix(): update postgres.utils.ts
1 parent e3845a6 commit eca2b0e

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

lib/common/postgres.utils.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { PostgresModuleOptions } from '../interfaces';
22
import { DEFAULT_CONNECTION_NAME } from '../postgres.constants';
33
import { Observable } from 'rxjs';
4-
import { delay, retry, scan } from 'rxjs/operators';
4+
import { delay, retryWhen, scan } from 'rxjs/operators';
55
import { randomUUID } from 'node:crypto';
66
import { Logger } from '@nestjs/common';
77
import { CircularDependencyException } from '../exceptions/circular-dependency.exception';
@@ -61,7 +61,7 @@ export function handleRetry(
6161
): <T>(source: Observable<T>) => Observable<T> {
6262
return <T>(source: Observable<T>) =>
6363
source.pipe(
64-
retry({ delay: (e) =>
64+
retryWhen((e) =>
6565
e.pipe(
6666
scan((errorCount, error: Error) => {
6767
logger.error(
@@ -77,7 +77,7 @@ export function handleRetry(
7777
}, 0),
7878
delay(retryDelay),
7979
),
80-
}),
80+
),
8181
);
8282
}
8383

0 commit comments

Comments
 (0)