import { Observable } from 'rxjs';
import { TextMessage, ImageMessage, NoteMessage, MediaMessage } from '../domain/message/message';
import { Id } from '../firebase/type';
import { MessageObserver } from './message';
import { AlreadyReadMessageObserver } from './alreadyReadMessage';
declare type MergeReadCount<T> = T & {
    readCount: number;
};
declare type RoomMessagesData = (MergeReadCount<TextMessage> | MergeReadCount<ImageMessage> | MergeReadCount<NoteMessage> | MergeReadCount<MediaMessage>)[];
export declare class RoomMessageObserver {
    private readonly messageObserver;
    private readonly alreadyReadMessageObserver;
    private readonly _roomMessages$;
    private readonly _close$;
    constructor(messageObserver: MessageObserver, alreadyReadMessageObserver: AlreadyReadMessageObserver);
    get roomMessages$(): Observable<RoomMessagesData>;
    fetchRoomMessage(roomId: Id, limit?: number, startAfter?: Date): void;
    dispose(): void;
}
export {};