kn/RealmSet.asResults

CHANGELOG.md

@@ -4,6 +4,7 @@
 * Deprecated `SyncResolveError` and `SyncResolveErrorCode` ([#1182](https://github.com/realm/realm-dart/pull/1182)).
 * Added `SyncWebSocketError` and `SyncWebSocketErrorCode` for web socket connection sync errors ([#1182](https://github.com/realm/realm-dart/pull/1182)).
 * Added `FlexibleSyncConfiguration.shouldCompactCallback` support ([#1204](https://github.com/realm/realm-dart/pull/1204)).
+* Added `RealmSet.asResults()` ([#1214](https://github.com/realm/realm-dart/pull/1214)).
 
 ### Fixed
 * You may have a crash on Windows if you try to open a file with non-ASCII path (Core upgrade).

lib/src/native/realm_core.dart

@@ -1067,6 +1067,11 @@ class _RealmCore {
     return RealmResultsHandle._(pointer, list.realm.handle);
   }
 
+  RealmResultsHandle resultsFromSet(RealmSet set) {
+    final pointer = _realmLib.invokeGetPointer(() => _realmLib.realm_set_to_results(set.handle._pointer));
+    return RealmResultsHandle._(pointer, set.realm.handle);
+  }
+
   Object? resultsGetElementAt(RealmResults results, int index) {
     return using((Arena arena) {
       final realm_value = arena<realm_value_t>();

lib/src/set.dart

@@ -27,6 +27,7 @@ import 'native/realm_core.dart';
 import 'realm_class.dart';
 import 'realm_object.dart';
 import 'collections.dart';
+import 'results.dart';
 
 /// RealmSet is a collection that contains no duplicate elements.
 abstract class RealmSet<T extends Object?> extends SetBase<T> with RealmEntity implements Finalizable {
@@ -95,6 +96,9 @@ abstract class RealmSet<T extends Object?> extends SetBase<T> with RealmEntity i
   /// ```
   @override
   bool remove(covariant T value); //Note: explicitly overriding remove() to change parameter type
+
+  /// Converts this [Set] to a [RealmResults].
+  RealmResults<T> asResults();
 }
 
 class UnmanagedRealmSet<T extends Object?> extends collection.DelegatingSet<T> with RealmEntity implements RealmSet<T> {
@@ -111,6 +115,9 @@ class UnmanagedRealmSet<T extends Object?> extends collection.DelegatingSet<T> w
 
   @override
   Stream<RealmSetChanges<T>> get changes => throw RealmStateError("Unmanaged RealmSets don't support changes");
+
+  @override
+  RealmResults<T> asResults() => throw RealmStateError("Unmanaged sets can't be converted to results");
 }
 
 class ManagedRealmSet<T extends Object?> with RealmEntity, SetMixin<T> implements RealmSet<T> {
@@ -248,6 +255,9 @@ class ManagedRealmSet<T extends Object?> with RealmEntity, SetMixin<T> implement
 
     return true;
   }
+
+  @override
+  RealmResults<T> asResults() => RealmResultsInternal.create<T>(realmCore.resultsFromSet(this), realm, _metadata);
 }
 
 /// @nodoc

test/realm_set_test.dart

@@ -16,8 +16,6 @@
 //
 ////////////////////////////////////////////////////////////////////////////////
 
-import 'dart:typed_data';
-
 import 'package:test/test.dart' hide test, throws;
 import '../lib/realm.dart';
 
@@ -645,4 +643,20 @@ Future<void> main([List<String>? args]) async {
     expect(testSet.objectsSet.length, 2);
     expect(realm.all<Car>().length, 2);
   });
+
+  test('RealmSet.asResults()', () {
+    var config = Configuration.local([TestRealmSets.schema, Car.schema]);
+    var realm = getRealm(config);
+
+    final cars = [Car("Tesla"), Car("Audi")];
+    final testSets = TestRealmSets(1)..objectsSet.addAll(cars);
+
+    expect(() => testSets.objectsSet.asResults(), throwsStateError); // unmanaged set
+
+    realm.write(() {
+      realm.add(testSets);
+    });
+
+    expect(testSets.objectsSet.asResults(), cars);
+  });
 }