Browser playground

⌘/Ctrl + Enter

Pipeline JavaScript const transactions = exstream(source('transactions'))
  .map((transaction) => ({
    ...transaction,
    risk: transaction.amount >= 5000 ? 'high' : 'normal',
  }))

const approved = transactions
  .fork()
  .filter((transaction) => transaction.risk === 'normal')

const review = transactions
  .fork()
  .filter((transaction) => transaction.risk === 'high')

await Promise.all([
  approved.pipeTo(destination('approved')),
  review.pipeTo(destination('manual-review')),
])

Pipeline

live telemetry

Run the pipeline to build its graph.

0 from script

Add destination('name') to the script.