Bump deps (w/ deprecation warnings) (#5378)
This commit is contained in:
@@ -263,9 +263,11 @@ export class RpcCore {
|
||||
}
|
||||
};
|
||||
}).pipe(
|
||||
// eslint-disable-next-line deprecation/deprecation
|
||||
publishReplay(1), // create a Replay(1)
|
||||
isDelayed
|
||||
? refCountDelay() // Unsubscribe after delay
|
||||
// eslint-disable-next-line deprecation/deprecation
|
||||
: refCount()
|
||||
);
|
||||
};
|
||||
|
||||
@@ -42,8 +42,10 @@ export function drr ({ delay, skipChange = false, skipTimeout = false }: Options
|
||||
skipChange
|
||||
? tap(NOOP)
|
||||
: distinctUntilChanged<T>(CMP),
|
||||
// eslint-disable-next-line deprecation/deprecation
|
||||
publishReplay(1),
|
||||
skipTimeout
|
||||
// eslint-disable-next-line deprecation/deprecation
|
||||
? refCount()
|
||||
: refCountDelay(delay)
|
||||
);
|
||||
|
||||
@@ -18,6 +18,7 @@ export function refCountDelay <T> (delay = 1750): MonoTypeOperatorFunction<T> {
|
||||
if (state === 1) {
|
||||
scheduler.unsubscribe();
|
||||
} else {
|
||||
// eslint-disable-next-line deprecation/deprecation
|
||||
connection = (source as ConnectableObservable<T>).connect();
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user