Function withRequestProgressSink

src/daemon/request-progress.ts:68–73

(
  sink: RequestProgressSink | undefined,
  run: () => Promise<T>,
)

>();

export async function withRequestProgressSink<T>(
  sink: RequestProgressSink | undefined,
  run: () => Promise<T>,
): Promise<T> {
  return await requestProgress.run(sink, run);
}

export function emitRequestProgress(event: RequestProgressEvent): void {
  requestProgress.getStore()?.(event);