import * as firebase from 'firebase'; import { Observable } from 'rxjs'; import { AlreadyReadMessage } from '../domain/account/alreadyReadMessage'; import { Id } from '../firebase/type'; export declare type AlreadyReadMessageDoc = Omit & { updatedAt: firebase.firestore.Timestamp; }; export declare function alreadyReadMessageMapper(alreadyReadMessageDoc: AlreadyReadMessageDoc): AlreadyReadMessage; declare type AlreadyReadMessageData = AlreadyReadMessage[]; export declare class AlreadyReadMessageObserver { private readonly _alreadyReadMessage$; private readonly _close$; private accountId; get alreadyReadMessages$(): Observable; fetchAlreadyReadMessages(roomId: Id, limit?: number, startAfter?: Date): void; dispose(): void; } export {};