import * as A from "@effect-ts/core/Collections/Immutable/Chunk";
import * as HM from "@effect-ts/core/Collections/Immutable/HashMap";
import { _R } from "@effect-ts/core/Effect";
import type * as DS from "../../DataSource/index.js";
import type { BlockedRequest } from "../BlockedRequest/index.js";
import type { BlockedRequests } from "../BlockedRequests/index.js";
import { Sequential } from "../Sequential/index.js";
/**
 * A `Parallel[R]` maintains a mapping from data sources to requests from
 * those data sources that can be executed in parallel.
 */
export declare class Parallel<R> {
    readonly map: HM.HashMap<DS.DataSource<unknown, unknown>, A.Chunk<BlockedRequest<unknown>>>;
    readonly [_R]: (r: R) => void;
    constructor(map: HM.HashMap<DS.DataSource<unknown, unknown>, A.Chunk<BlockedRequest<unknown>>>);
}
/**
 * Combines this collection of requests that can be executed in parallel
 * with that collection of requests that can be executed in parallel to
 * return a new collection of requests that can be executed in parallel.
 */
export declare function add<R1>(that: Parallel<R1>): <R>(self: Parallel<R>) => Parallel<R & R1>;
export declare function add_<R, R1>(self: Parallel<R>, that: Parallel<R1>): Parallel<R & R1>;
/**
 * Returns whether this collection of requests is empty.
 */
export declare function isEmpty<R>(self: Parallel<R>): boolean;
/**
 * Returns a collection of the data sources that the requests in this
 * collection are from.
 */
export declare function keys<R>(self: Parallel<R>): Iterable<DS.DataSource<R, unknown>>;
/**
 * Converts this collection of requests that can be executed in parallel to
 * a batch of requests in a collection of requests that must be executed
 * sequentially.
 */
export declare function sequential<R>(self: Parallel<R>): Sequential<R>;
/**
 * Converts this collection of requests that can be executed in parallel to
 * an `Iterable` containing mappings from data sources to requests from
 * those data sources.
 */
export declare function toIterable<R>(self: Parallel<R>): Iterable<readonly [DS.DataSource<R, unknown>, A.Chunk<A.Chunk<BlockedRequests<unknown>>>]>;
/**
 * The empty collection of requests.
 */
export declare const empty: Parallel<unknown>;
/**
 * Constructs a new collection of requests containing a mapping from the
 * specified data source to the specified request.
 */
export declare function apply<R, A>(dataSource: DS.DataSource<R, A>, blockedRequest: BlockedRequest<A>): Parallel<R>;
//# sourceMappingURL=index.d.ts.map