import type { ISubject } from "./types"; import { type IEmitter, type ISubscription, type IUnsubscriber } from "./types"; import SubjectMY from "./Subject"; export default class ReplaySubject extends SubjectMY implements ISubject { private readonly bufferSize; private readonly buffer; private cursorEnd; private cursorStart; constructor(bufferSize: number); next(value: T): void; protected _subscribe(emitter: IEmitter): IUnsubscriber | ISubscription | void; }