// All changes (local and server)
talon.changes.listen((change) { ... });

// Only server changes
talon.serverChanges.listen((change) { ... });

// Only local changes
talon.localChanges.listen((change) { ... });

class TalonChange {
  final TalonChangeSource source;  // local or server
  final List<Message> messages;    // The changes

  // Helper methods
  List<Message> forTable(String table);
  bool affectsTable(String table);
  bool affectsRow(String table, String row);
}

talon.changes.listen((change) {
  if (change.affectsTable('todos')) {
    refreshTodoList();
  }
});

talon.serverChanges.listen((change) {
  // Show notification for new data
  if (change.affectsTable('messages')) {
    showNewMessageNotification();
  }
});

talon.changes.listen((change) {
  if (change.affectsRow('todos', currentTodoId)) {
    refreshCurrentTodo();
  }
});

talon.changes.listen((change) {
  for (final message in change.forTable('todos')) {
    print('${message.column} changed to ${message.typedValue}');
  }
});

class _MyState extends State<MyWidget> {
  late StreamSubscription _sub;

  @override
  void initState() {
    super.initState();
    _sub = talon.changes.listen((_) => refresh());
  }

  @override
  void dispose() {
    _sub.cancel();  // Important!
    super.dispose();
  }
}

Timer? _refreshTimer;

talon.changes.listen((change) {
  if (change.affectsTable('todos')) {
    _refreshTimer?.cancel();
    _refreshTimer = Timer(Duration(milliseconds: 100), () {
      refreshTodoList();
    });
  }
});

// Only react to server changes (avoid reacting to own changes)
talon.serverChanges.listen((change) {
  showSyncIndicator();
  refreshData();
});