///
import { EventEmitter } from "events";
import { ChangeStream, MongoClient } from "mongodb";
import { IDocumentClass, IRepositoryOptions } from "../types";
export declare class ChangeStreamWrapper
extends EventEmitter {
readonly changeStream: ChangeStream;
readonly mongoClient: MongoClient;
readonly classObject: TD;
readonly dbName: string;
readonly collectionName: string;
constructor(options: IRepositoryOptions | );
isClosed(): boolean;
close(): Promise;
private _onChange;
private _onEnd;
private _onClose;
private _onError;
private _parseChangeEvent;
}
|