import * as grpc from '@grpc/grpc-js';
import { ClientDuplexStream, ClientReadableStream, ClientUnaryCall, ClientWritableStream } from '@grpc/grpc-js';
import * as protobufjs from 'protobufjs';
export declare function decodeAnyMessageRecursively(root: protobufjs.Root, message?: unknown, decodeAnyMessageProtoLoaderOptions?: protobufjs.IConversionOptions): unknown;
export declare function isRetryableGrpcError(error?: grpc.ServiceError): boolean;
export declare function isRecreateServiceError(error?: grpc.ServiceError): boolean;
export type ListenForAbortArgs = {
    signal?: AbortSignal;
    config: {
        abortOnClientDisconnect?: boolean;
    };
    call: ClientUnaryCall | ClientReadableStream<unknown> | ClientWritableStream<unknown> | ClientDuplexStream<unknown, unknown>;
    reject: (err: Error) => void;
};
export declare function listenForAbort({ signal, config, call, reject }: ListenForAbortArgs): () => void;