Tips for using Neon + Pulse + tRPC for real-time updates

 onChanges: protectedProcedure.subscription(async function* ({ ctx }) {
    const events = await ctx.db.modelToUpdate.subscribe();

    console.log("Initializing Pulse subscription");

    for await (const event of events) {
      console.log("document event", event);

      yield event;
    }
  }),
~

 const documentSubscription = api.xxx.onChanges.useSubscription(
    undefined,
    {
      onData: (data) => {
        console.log("Pulse update received");
      }
    }
  );