Control event bursts

Burst controls operate across trigger contexts. Partition the source with keyBy when each customer or record needs independent timing, or globally when every occurrence should share one timer.

Result	Operator
Most recent occurrence after activity stops	`debounce`
Every occurrence before a relative or absolute deadline	`window`
Leading, trailing, minimum-gap, selection, or buffering policy	`funnel`

automations/debounce-customer-updates.automation.ts

import { automation, onInvocation, sendEmail, t } from "automate.ax"

export default automation("Debounce customer updates", () => {
  const update = onInvocation<{ customerId: string; summary: string }>()
  const settled = update.keyBy((value) => value.customerId).debounce("5m")

  sendEmail({ subject: "Customer update", text: t`${settled.summary}` })
})

Each occurrence resets only its partition’s timer. Each emission creates a child context containing the selected source histories, so downstream actions can consume the burst result and inherited source values. Use collect when batch size, not time, closes the group. Use delay to resume one causal occurrence later.

Start

Concepts

Guides