import * as Effect from "effect-app/Effect";
import * as S from "effect-app/Schema";
import * as Tracer from "effect/Tracer";
import { MemQueue } from "../adapters/memQueue.js";
export declare const makeMemQueue: <Evt extends {
    id: S.StringId;
    _tag: string;
}, DrainEvt extends {
    id: S.StringId;
    _tag: string;
}, EvtE, DrainEvtE>(queueName: string, queueDrainName: string, schema: S.Codec<Evt, EvtE, never, never>, drainSchema: S.Codec<DrainEvt, DrainEvtE, never, never>) => Effect.Effect<{
    publish: (args_0: Evt, ...args: Evt[]) => Effect.Effect<void, never, never>;
    drain: <DrainE, DrainR>(handleEvent: (ks: DrainEvt) => Effect.Effect<void, DrainE, DrainR>, sessionId?: string) => Effect.Effect<never, never, Exclude<Exclude<DrainR, Tracer.ParentSpan>, never>>;
}, never, MemQueue>;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoibWVtUXVldWUuZC50cyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9RdWV1ZU1ha2VyL21lbVF1ZXVlLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUNBLE9BQU8sS0FBSyxNQUFNLE1BQU0sbUJBQW1CLENBQUE7QUFDM0MsT0FBTyxLQUFLLENBQUMsTUFBTSxtQkFBbUIsQ0FBQTtBQU10QyxPQUFPLEtBQUssTUFBTSxNQUFNLGVBQWUsQ0FBQTtBQUN2QyxPQUFPLEVBQUUsUUFBUSxFQUFFLE1BQU0seUJBQXlCLENBQUE7QUFPbEQsZUFBTyxNQUFNLFlBQVksR0FDdkIsR0FBRyxTQUFTO0lBQUUsRUFBRSxFQUFFLENBQUMsQ0FBQyxRQUFRLENBQUM7SUFBQyxJQUFJLEVBQUUsTUFBTSxDQUFBO0NBQUUsRUFDNUMsUUFBUSxTQUFTO0lBQUUsRUFBRSxFQUFFLENBQUMsQ0FBQyxRQUFRLENBQUM7SUFBQyxJQUFJLEVBQUUsTUFBTSxDQUFBO0NBQUUsRUFDakQsSUFBSSxFQUNKLFNBQVM7O1lBOENDLE1BQU0sRUFBRSxNQUFNLGVBQ1AsQ0FBQyxFQUFFLEVBQUUsUUFBUSxLQUFLLE1BQU0sQ0FBQyxNQUFNLENBQUMsSUFBSSxFQUFFLE1BQU0sRUFBRSxNQUFNLENBQUMsY0FDdEQsTUFBTTttQkFtRXRCLENBQUEifQ==