import { WeftError } from '../../core/weft-error.ts';
import type { OperationFault } from '../operation-fault.ts';
import { type DispatchContext, type DispatchResult } from './types.ts';
/**
 * Error thrown when an element emitted by a subscription or stream fails
 * per-element schema validation.
 */
export declare class SubscriptionElementValidationError extends WeftError<'SubscriptionElementValidationError'> {
    readonly fault: OperationFault;
    constructor(fault: OperationFault);
}
/**
 * Execute a `kind: 'stream'` operation and return a schema-validating
 * async iterable for its emitted elements.
 */
export declare function executeStream<Element>(operationName: string, rawInput: unknown, context: DispatchContext): Promise<DispatchResult<AsyncIterable<Element>>>;
/**
 * Execute a `kind: 'subscription'` operation and return its validated
 * subscribe envelope, schema-validating element iterable, and close hook.
 */
export declare function executeSubscription<Element, Envelope>(operationName: string, rawInput: unknown, context: DispatchContext): Promise<DispatchResult<{
    envelope: Envelope;
    iterable: AsyncIterable<Element>;
    close: () => Promise<void>;
}>>;