demo.ts

// VERSION 1

// subscribe to all changes on the `User` table
const s = await prisma.user.subscribe()

// wait for new events to arrive
for await (let event of s) {
  
  // log the details about an event to the terminal
  console.log(`Something happened in the database: `)
  console.log(event)
}


// VERSION 2

// subscribe to all changes on the `User` table
const stream = await prisma.user.stream()

// wait for new events to arrive
for await (let event of s) {
  
  // log the details about an event to the terminal
  console.log(`Something happened in the database: `)
  console.log(event)
}