import { Tracer } from "effect";
import { Effect, S } from "effect-app";
import type { StringId } from "effect-app/Schema";
import { Receiver, Sender } from "../adapters/ServiceBus.js";
export declare function makeServiceBusQueue<Evt extends {
    id: StringId;
    _tag: string;
}, DrainEvt extends {
    id: StringId;
    _tag: string;
}, EvtE, DrainEvtE>(schema: S.Codec<Evt, EvtE>, drainSchema: S.Codec<DrainEvt, DrainEvtE>): Effect.Effect<{
    drain: <DrainE, DrainR>(handleEvent: (ks: DrainEvt) => Effect.Effect<void, DrainE, DrainR>, sessionId?: string) => Effect.Effect<never, never, import("effect/Scope").Scope | Exclude<Exclude<DrainR, Tracer.ParentSpan>, never>>;
    publish: (args_0: Evt, ...args: Evt[]) => Effect.Effect<void, never, never>;
}, never, Receiver | Sender>;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic2JxdWV1ZS5kLnRzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vc3JjL1F1ZXVlTWFrZXIvc2JxdWV1ZS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiQUFBQSxPQUFPLEVBQUUsTUFBTSxFQUFFLE1BQU0sUUFBUSxDQUFBO0FBQy9CLE9BQU8sRUFBUyxNQUFNLEVBQW9DLENBQUMsRUFBRSxNQUFNLFlBQVksQ0FBQTtBQUMvRSxPQUFPLEtBQUssRUFBRSxRQUFRLEVBQUUsTUFBTSxtQkFBbUIsQ0FBQTtBQUVqRCxPQUFPLEVBQUUsUUFBUSxFQUFFLE1BQU0sRUFBRSxNQUFNLDJCQUEyQixDQUFBO0FBTTVELHdCQUFnQixtQkFBbUIsQ0FDakMsR0FBRyxTQUFTO0lBQUUsRUFBRSxFQUFFLFFBQVEsQ0FBQztJQUFDLElBQUksRUFBRSxNQUFNLENBQUE7Q0FBRSxFQUMxQyxRQUFRLFNBQVM7SUFBRSxFQUFFLEVBQUUsUUFBUSxDQUFDO0lBQUMsSUFBSSxFQUFFLE1BQU0sQ0FBQTtDQUFFLEVBQy9DLElBQUksRUFDSixTQUFTLEVBRVQsTUFBTSxFQUFFLENBQUMsQ0FBQyxLQUFLLENBQUMsR0FBRyxFQUFFLElBQUksQ0FBQyxFQUMxQixXQUFXLEVBQUUsQ0FBQyxDQUFDLEtBQUssQ0FBQyxRQUFRLEVBQUUsU0FBUyxDQUFDO1lBdUI3QixNQUFNLEVBQUUsTUFBTSxlQUNQLENBQUMsRUFBRSxFQUFFLFFBQVEsS0FBSyxNQUFNLENBQUMsTUFBTSxDQUFDLElBQUksRUFBRSxNQUFNLEVBQUUsTUFBTSxDQUFDLGNBQ3RELE1BQU07OzZCQWdFekIifQ==