import { Effect, Stream } from 'effect';
import { type ChangeNotice, type DecodedEntity, type DecodedSingleEntity } from '../../../core/index.js';
import { DatabaseError } from '../error/index.js';
import { type ContractFailure } from '../contract/index.js';
export declare const dbError: (operation: string, failure: ContractFailure, entity?: string) => DatabaseError;
export declare const failReason: (reason: DatabaseError['reason']) => Effect.Effect<never, DatabaseError, never>;
export declare const broadcast: (entity: DecodedEntity<object> | DecodedSingleEntity<object>) => Effect.Effect<void, never, never>;
export declare const changesOrEmpty: () => Stream.Stream<DecodedEntity<any>>;
export declare const subscribe: <T extends object>(entityName: string, filter: Partial<T> | undefined) => Stream.Stream<ChangeNotice<T>>;
//# sourceMappingURL=effects.d.ts.map