import { Message as GoogleMessage } from 'google-protobuf';
import { ActorRunTrialOutput } from './api/common_pb';
import { RecvEvent } from './ClientService';
import { ActorImplementation } from './Context';
import { Trial } from './Trial';
import { MessageBase } from './types';
export declare class Ending {
}
export declare class EndingAck {
}
export declare class Session<ActionT extends MessageBase, ObservationT extends MessageBase> {
    trial: Trial;
    name: string;
    protected impl: ActorImplementation<ActionT, ObservationT>;
    config?: import("./types/UtilTypes").Message | undefined;
    private eventQueue;
    private started;
    private lastEventDelivered;
    private dataQueue;
    autoAck: boolean;
    private activeActors;
    constructor(trial: Trial, name: string, impl: ActorImplementation<ActionT, ObservationT>, config?: import("./types/UtilTypes").Message | undefined);
    internalStart: (autoDoneSending: boolean) => void;
    newEvent: (event: RecvEvent<ActionT, ObservationT>) => void;
    postData: (data: GoogleMessage | Ending | EndingAck) => void;
    retrieveData(): AsyncGenerator<GoogleMessage | Ending | EndingAck | ActorRunTrialOutput, void, unknown>;
    sendingDone: () => void;
    eventLoop(): AsyncGenerator<RecvEvent<ActionT, ObservationT>, void, unknown>;
    getTrialId: () => string;
    getTickId: () => number;
    isTrialOver: () => boolean;
    exitQueues: () => void;
    addReward: (value: number, confidence: number, to: string[], tickId?: number, userData?: MessageBase | null) => void;
    protected sendMessageInternal(payload: MessageBase, to: string[]): void;
}
//# sourceMappingURL=Session.d.ts.map