import { grpc } from '@improbable-eng/grpc-web';
import { Message, Message as MessageGrpc } from 'google-protobuf';
import { MessageBase, MessageClass } from '../cogment/types/UtilTypes';
import { google } from '../cogment/api/common_pb_2';
export type Status = {
    details: string;
    code: number;
    metadata: grpc.Metadata;
};
interface ResponseStream<T> {
    cancel(): void;
    on(type: 'data', handler: (message: T) => void): ResponseStream<T>;
    on(type: 'end', handler: (status?: Status) => void): ResponseStream<T>;
    on(type: 'status', handler: (status: Status) => void): ResponseStream<T>;
}
interface BidirectionalStream<ReqT, ResT> {
    write(message: ReqT): BidirectionalStream<ReqT, ResT>;
    end(): void;
    cancel(): void;
    on(type: 'data', handler: (message: ResT) => void): BidirectionalStream<ReqT, ResT>;
    on(type: 'end', handler: (status?: Status) => void): BidirectionalStream<ReqT, ResT>;
    on(type: 'status', handler: (status: Status) => void): BidirectionalStream<ReqT, ResT>;
}
export declare const base64ToUint8Array: (base64: string) => Uint8Array;
export declare const streamToGenerator: <S extends Message, T extends Message>(stream: BidirectionalStream<S, T> | ResponseStream<T>) => () => AsyncGenerator<T, void, unknown>;
export declare const streamToQueue: <S extends Message, T extends Message>(stream: BidirectionalStream<S, T> | ResponseStream<T>, requestQueue?: AsyncQueue<S> | undefined) => AsyncQueue<T>;
export declare class AsyncQueue<T> {
    private data;
    private nextDataResolve;
    private nextDataPromise;
    constructor();
    put: (newData: T) => void;
    get: () => Promise<T | undefined>;
    end: () => void;
}
export declare const staticCastFromGoogle: <T extends import("../cogment/types/UtilTypes").Message>(source: MessageGrpc, destClass: MessageClass) => T;
export declare const encodePbMessage: (messageClass: MessageClass, message: MessageBase) => Uint8Array;
export declare const messageToAnyPB: (message: MessageBase) => google.protobuf.Any;
export {};
//# sourceMappingURL=Utils.d.ts.map