diff --git a/src/internal/ReplaySubject.ts b/src/internal/ReplaySubject.ts index 12a2fc99b4..ac71b809ff 100644 --- a/src/internal/ReplaySubject.ts +++ b/src/internal/ReplaySubject.ts @@ -81,7 +81,7 @@ export class ReplaySubject extends Subject { subscriber.next(copy[i] as T); } - this.checkFinalizedStatuses(subscriber); + this._checkFinalizedStatuses(subscriber); return subscription; } diff --git a/src/internal/operators/skipLast.ts b/src/internal/operators/skipLast.ts index 7c644d8ebf..f6a3e95b43 100644 --- a/src/internal/operators/skipLast.ts +++ b/src/internal/operators/skipLast.ts @@ -42,6 +42,7 @@ import { OperatorSubscriber } from './OperatorSubscriber'; * @name skipLast */ export function skipLast(skipCount: number): MonoTypeOperatorFunction { + // For skipCounts less than or equal to zero, we are just mirroring the source. return (source: Observable) => skipCount <= 0 ? source : lift(source, function (this: Subscriber, source: Observable) { const subscriber = this; // A ring buffer to hold the values while we wait to see