convert openConnection retryWhen (deprecated) to retry

CHANGELOG.md

@@ -1,3 +1,9 @@
+## [5.0.1](https://github.com/sketch7/signalr-client/compare/5.0.0...5.0.1) (2023-09-11)
+
+### Refactor
+
+- **hub connection:** convert `openConnection` `retryWhen` (deprecated) to `retry`
+
 ## [5.0.0](https://github.com/sketch7/signalr-client/compare/4.1.0...5.0.0) (2023-09-08)
 
 ### Features

src/lib/hub-connection.ts

@@ -1,7 +1,7 @@
 import { from, BehaviorSubject, Observable, Observer, timer, throwError, Subject } from "rxjs";
 import {
 	tap, map, filter, switchMap, skipUntil, delay, first,
-	retryWhen, scan, delayWhen, distinctUntilChanged, takeUntil
+	retryWhen, delayWhen, distinctUntilChanged, takeUntil,retry
 } from "rxjs/operators";
 import {
 	HubConnection as SignalRHubConnection,
@@ -240,9 +240,8 @@ export class HubConnection<THub> {
 			tap(() => this._connectionState$.next(connectingState)),
 			switchMap(() => from(this.hubConnection.start())),
 			// tap(x => console.warn(">>>> [openConnection] - connection established", x)),
-			retryWhen(errors => errors.pipe(
-				scan((errorCount: number) => ++errorCount, 0),
-				delayWhen((retryCount: number) => {
+			retry({
+				delay: (error, retryCount) => {
 					if (this.retry.maximumAttempts && retryCount > this.retry.maximumAttempts) {
 						return throwError(() => new Error(errorCodes.retryLimitsReached));
 					}
@@ -258,8 +257,8 @@ export class HubConnection<THub> {
 					this.hubConnectionOptions$.next(this.hubConnectionOptions$.value);
 
 					return timer(nextRetryMs);
-				})
-			)),
+				}
+			}),
 			tap(() => this.internalConnStatus$.next(InternalConnectionStatus.connected)),
 			tap(() => this._connectionState$.next(connectedState)),
 			takeUntil(this.untilDesiredDisconnects$()),