import { Observable } from 'rxjs';
import { EventResponse, EventType, EventStreamWebsocket } from './types';
import { EventFilter } from './event-filter';
export declare class EventStream {
    private ws;
    private message$;
    private _serviceMessage$;
    private _connectionStateChanged$;
    private _serviceStateChanged$;
    private _heartbeat$;
    private subscription$;
    private _event$;
    private recentCharacterIds$;
    private _achievementEarned$;
    private _battleRankUp$;
    private _death$;
    private _itemAdded$;
    private _skillAdded$;
    private _vehicleDestroy$;
    private _gainExperience$;
    private _playerFacilityCapture$;
    private _playerFacilityDefend$;
    private _continentLock$;
    private _continentUnlock$;
    private _facilityControl$;
    private _metagameEvent$;
    private _playerLogin$;
    private _playerLogout$;
    readonly serviceMessage$: Observable<any>;
    readonly connectionStateChanged$: Observable<boolean>;
    readonly serviceStateChanged$: Observable<boolean>;
    readonly heartbeat$: Observable<any>;
    readonly event$: Observable<any>;
    readonly achievementEarned$: Observable<EventType.AchievementEarned>;
    readonly battleRankUp$: Observable<EventType.BattleRankUp>;
    readonly death$: Observable<EventType.Death>;
    readonly itemAdded$: Observable<EventType.ItemAdded>;
    readonly skillAdded$: Observable<EventType.SkillAdded>;
    readonly vehicleDestroy$: Observable<EventType.VehicleDestroy>;
    readonly gainExperience$: Observable<EventType.GainExperience>;
    readonly playerFacilityCapture$: Observable<EventType.PlayerFacilityCapture>;
    readonly playerFacilityDefend$: Observable<EventType.PlayerFacilityDefend>;
    readonly continentLock$: Observable<EventType.ContinentLock>;
    readonly continentUnlock$: Observable<EventType.ContinentUnlock>;
    readonly facilityControl$: Observable<EventType.FacilityControl>;
    readonly metagameEvent$: Observable<EventType.MetagameEvent>;
    readonly playerLogin$: Observable<EventType.PlayerLogin>;
    readonly playerLogout$: Observable<EventType.PlayerLogout>;
    constructor(ws: EventStreamWebsocket);
    private typeFilter(typeName);
    private filterServiceMessage(memberName);
    private filterEvent(eventName);
    private sendCommand(action, options?);
    private sendSubscribeCommand(action, events, filter, logicalAnd?);
    private waitForSubscribe();
    connect(): Promise<void>;
    disconnect(): Promise<void>;
    addEvent(events: string[], filter: EventFilter, logicalAnd?: boolean): Promise<EventResponse.Subscription>;
    removeEvent(events: string[], filter: EventFilter, logicalAnd?: boolean): Promise<EventResponse.Subscription>;
    removeAllEvent(): Promise<EventResponse.Subscription>;
    private waitRecentCharacterIds();
    getRecentCharacterIds(): Promise<EventResponse.RecentCharacterIds>;
    getRecentCharacterIdsCount(): Promise<EventResponse.RecentCharacterIds>;
}