@stoplight/graphite/scheduler/scheduler.d.ts

import { Resolver } from '@stoplight/json-ref-resolver';
import { IGraph, NodeInstance } from '../graph';
import { GraphTask, IScheduler, ISchedulerStateSnapshot, ITaskHandler } from '../scheduler';
export declare function createScheduler(props: ISchedulerProps): Scheduler;
export interface ISchedulerProps {
    graph: IGraph;
    resolver: Resolver;
}
declare class Scheduler implements IScheduler {
    private _graph;
    private _queue;
    private readonly _resolver;
    private _queued;
    private _handlers;
    private _running;
    mightBeStuck: boolean;
    private _mightBeStuckTimeout?;
    constructor(props: ISchedulerProps);
    get isBusy(): boolean;
    get queuedCount(): number;
    snapshot(): ISchedulerStateSnapshot;
    queue: (task: GraphTask) => Promise<void>;
    queueAll: (tasks: GraphTask[]) => Promise<void>[];
    queueLength(): number;
    registerHandler: <T extends GraphTask = GraphTask, N extends NodeInstance = NodeInstance>(op: T["op"], handler: ITaskHandler<T, N>) => import("@stoplight/lifecycle").IDisposable;
    drain: () => Promise<void>;
    run(task: GraphTask): Promise<void>;
    private _run;
    private drainQueue;
    private _runQueueTask;
    private _handleRunResult;
}
export {};