import { Observable } from 'rxjs';
import { ServerGatewayMessage } from '../../Gateway/ValueObject/ServerGatewayMessage';
import { ServerGatewayMetadata } from '../../Gateway/ValueObject/ServerGatewayMetadata';
import { QueryAction } from '../QueryAction';
/**
 * Emit success or error action on client gateway.
 */
export declare function emitQueryHandlerResponseOrErrorToClientGateway<T extends ServerGatewayMessage<ServerGatewayMetadata<any>>>(handleMessages$: (input: Observable<T>) => Observable<unknown>, convertError?: (error: unknown) => unknown): (input: Observable<T>) => Observable<QueryAction<import("../SerializableQuery").SerializableQuery, {}>>;