Every agent action starts as a message.

const shop = laser.stream("shop")
const topic = shop.topic("orders")
await topic.ensure(2)

for (const order of ORDERS) {
  await topic.publish().json(order).send()
}

// one typed handle: Order in, Order out
const replay = await topic
  .json(ORDER_CODEC)
  .records("log-example")
const batch = await replay.poll()
for (const result of batch) {
  if (result.kind === "record") {
    console.log(result.record.value.total)
  }
}