import { NextClawClientOptions } from "../types/nextclaw-request.types.js";
import { RequestService } from "./request.service.js";
import { AgentRunSendIngressPayload } from "@nextclaw/shared";
import { NcpEndpointEvent, NcpMessageAbortPayload, NcpRunHandle, NcpStreamRequestPayload } from "@nextclaw/ncp";

//#region src/services/agent-runs.service.d.ts
type NextClawAgentRunStreamHandler = (event: NcpEndpointEvent) => void;
type NextClawAgentRunStreamOptions = {
  onError?: (error: unknown) => void;
  signal?: AbortSignal;
};
type NextClawAgentRunStreamSubscription = {
  close: () => void;
};
declare class AgentRunsService {
  private readonly requestService;
  private readonly baseUrl;
  private readonly defaultHeaders;
  private readonly fetchImpl;
  private readonly transport;
  constructor(requestService: RequestService, options: NextClawClientOptions);
  send: (payload: AgentRunSendIngressPayload) => Promise<NcpRunHandle>;
  abort: (payload: NcpMessageAbortPayload) => Promise<{
    accepted: true;
  }>;
  stream: (payload: NcpStreamRequestPayload, handler: NextClawAgentRunStreamHandler, options?: NextClawAgentRunStreamOptions) => NextClawAgentRunStreamSubscription;
  private consumeStream;
  private readEventStream;
  private drainFrames;
}
//#endregion
export { AgentRunsService, NextClawAgentRunStreamHandler, NextClawAgentRunStreamOptions, NextClawAgentRunStreamSubscription };
//# sourceMappingURL=agent-runs.service.d.ts.map