import type { StreamData, StreamDataResponse } from '@hotmeshio/hotmesh/build/types/stream';
import type { ActivityManifestEntry } from '../../../types/yaml-workflow';
/**
 * Wrap a worker callback with activity lifecycle event publishing.
 * Publishes activity.started before and activity.completed/failed after.
 */
export declare function wrapWithEvents(activity: ActivityManifestEntry, appId: string, stepIndex: number, totalSteps: number, callback: (data: StreamData) => Promise<StreamDataResponse>): (data: StreamData) => Promise<StreamDataResponse>;