wip

Author: stephencelis

Examples/GRDBDemo/GRDB/GRDBQueryKey.swift

@@ -101,6 +101,15 @@ struct GRDBQueryKey<Value: Sendable>: SharedReaderKey {
     try databaseQueue.read(query.fetch)
   }
 
+  func load(
+    initialValue: Value?,
+    didReceive callback: @escaping @Sendable (Result<Value?, any Error>) -> Void
+  ) {
+    databaseQueue.asyncRead { result in
+      callback(result.flatMap { db in Result { try query.fetch(db) } })
+    }
+  }
+
   func subscribe(
     initialValue: Value?,
     didReceive callback: @escaping @Sendable (Result<Value?, any Error>) -> Void

Sources/Sharing/SharedReader.swift

@@ -190,6 +190,9 @@ public struct SharedReader<Value> {
     reference.loadError
   }
 
+  // $players.isLoading { … } else if $players.loadError { … } else { }
+  // TODO: public var isLoading: Bool
+
   /// Requests an up-to-date value from an external source.
   ///
   /// When a shared reference is powered by a ``SharedReaderKey``, this method will tell it to

Sources/Sharing/SharedReaderKey.swift

@@ -145,6 +145,7 @@ extension SharedReader {
   }
 
   // TODO: Non-async version of 'init(require:)'?
+  // TODO: Chopping block for 2.0?
 
   /// Creates a shared reference to a read-only value using a shared key.
   ///
@@ -154,11 +155,7 @@ extension SharedReader {
   /// - Parameter key: A shared key associated with the shared reference. It is responsible for
   ///   loading and saving the shared reference's value from some external source.
   public init(require key: some SharedReaderKey<Value>) async throws {
-    let value = try await withUnsafeThrowingContinuation { continuation in
-      key.load(initialValue: nil) { result in
-        continuation.resume(with: result)
-      }
-    }
+    let value = try await key.load(initialValue: nil)
     guard let value else { throw LoadError() }
     self.init(rethrowing: value, key)
     if let loadError { throw loadError }
@@ -167,11 +164,7 @@ extension SharedReader {
   @_disfavoredOverload
   @_documentation(visibility: private)
   public init(require key: some SharedKey<Value>) async throws {
-    let value = try await withUnsafeThrowingContinuation { continuation in
-      key.load(initialValue: nil) { result in
-        continuation.resume(with: result)
-      }
-    }
+    let value = try await key.load(initialValue: nil)
     guard let value else { throw LoadError() }
     self.init(rethrowing: value, key)
     if let loadError { throw loadError }