refactor: use list of unique columns

lib/src/supabase_query_builder.dart

@@ -41,6 +41,8 @@ class SupabaseQueryBuilder extends PostgrestQueryBuilder {
 
   /// Notifies of data at the queried table
   ///
+  /// [uniqueColumns] can be either the primary key or a combination of unique columns.
+  ///
   /// ```dart
   /// supabase.from('chats').stream('my_primary_key').execute().listen(_onChatsReceived);
   /// ```
@@ -50,11 +52,11 @@ class SupabaseQueryBuilder extends PostgrestQueryBuilder {
   /// ```dart
   /// supabase.from('chats:room_id=eq.123').stream('my_primary_key').order('created_at').limit(20).execute().listen(_onChatsReceived);
   /// ```
-  SupabaseStreamBuilder stream(String primaryKey) {
+  SupabaseStreamBuilder stream(List<String> uniqueColumns) {
     return SupabaseStreamBuilder(
       this,
       streamFilter: _streamFilter,
-      primaryKey: primaryKey,
+      uniqueColumns: uniqueColumns,
     );
   }
 }

lib/src/supabase_stream_builder.dart

@@ -41,15 +41,15 @@ class SupabaseStreamBuilder {
   late final StreamPostgrestFilter? _streamFilter;
 
   /// Used to identify which row has changed
-  final String _primaryKey;
+  final List<String> _uniqueColumns;
 
   SupabaseStreamBuilder(
     SupabaseQueryBuilder queryBuilder, {
     required StreamPostgrestFilter? streamFilter,
-    required String primaryKey,
+    required List<String> uniqueColumns,
   })  : _queryBuilder = queryBuilder,
         _streamFilter = streamFilter,
-        _primaryKey = primaryKey;
+        _uniqueColumns = uniqueColumns;
 
   /// Which column to order by and whether it's ascending
   _Order? _orderBy;
@@ -72,7 +72,7 @@ class SupabaseStreamBuilder {
   /// Limits the result with the specified `count`.
   ///
   /// ```dart
-  /// supabase.from('users').stream('id).limit(10);
+  /// supabase.from('users').stream('id').limit(10);
   /// ```
   SupabaseStreamBuilder limit(int count) {
     _limit = count;
@@ -160,8 +160,8 @@ class SupabaseStreamBuilder {
     } else if (payload.eventType == 'DELETE') {
       targetRecord = payload.oldRecord!;
     }
-
-    return record[_primaryKey] == targetRecord[_primaryKey];
+    return _uniqueColumns
+        .every((column) => record[column] == targetRecord[column]);
   }
 
   void _sortData() {