/** * Defines an optional contract a `@reactor`/`@reducer`-decorated class instance can implement to * receive notifications when replay of a specific partition begins and ends. */ export interface ICanBeNotifiedWhenPartitionReplayed { /** * Called when replay of a partition begins. * @param partition - The partition being replayed. * @returns A promise that resolves when the callback has completed. */ beginReplayPartition(partition: string): Promise; /** * Called when replay of a partition ends. * @param partition - The partition that was replayed. * @returns A promise that resolves when the callback has completed. */ endReplayPartition(partition: string): Promise; } //# sourceMappingURL=ICanBeNotifiedWhenPartitionReplayed.d.ts.map