LiveData

import { LiveData } from 'modelence/server';

...

 getTodos({ userId }, context) {
   return new LiveData({
     fetch: async () => await dbTodos.fetch({ userId }),
     watch: ({ publish }) => {
       // Subscribe to changes and call publish when data changes
       listener.onChange(publish);

       return () => {
         // Cleanup function to unsubscribe from changes
       };
     }
   });
 }