import { Message, MethodKind } from "@bufbuild/protobuf"; import type { HandlerContext, MethodImplSpec } from "../implementation.js"; import type { AsyncIterableTransform } from "./async-iterable.js"; /** * Invoke a user-provided implementation of a unary RPC. Returns a normalized * output message. * * @private Internal code, does not follow semantic versioning. */ export declare function invokeUnaryImplementation, O extends Message>(spec: MethodImplSpec & { kind: MethodKind.Unary; }, context: HandlerContext, input: I): Promise; /** * Return an AsyncIterableTransform that invokes a user-provided implementation, * giving it input from an asynchronous iterable, and returning its output as an * asynchronous iterable. * * @private Internal code, does not follow semantic versioning. */ export declare function transformInvokeImplementation, O extends Message>(spec: MethodImplSpec, context: HandlerContext): AsyncIterableTransform;