Merge pull request #64 from ChristophKaser/assert_no_failure

adds QueryableOptions.assertNoFailure to treat errors as fatalError

Author: groue

Sources/GRDBQuery/Queryable+DatabaseContext/FetchQueryable.swift

@@ -55,6 +55,7 @@ extension TopLevelDatabaseReader {
                     .eraseToAnyPublisher()
             }
         }
+        .assertNoFailure(if: queryableOptions.contains(.assertNoFailure))
         .eraseToAnyPublisher()
     }
 }

Sources/GRDBQuery/Queryable+DatabaseContext/QueryableOptions.swift

@@ -7,6 +7,7 @@
 ///
 /// - ``async``
 /// - ``constantRegion``
+/// - ``assertNoFailure``
 public struct QueryableOptions: OptionSet, Sendable {
     public let rawValue: Int
 
@@ -58,6 +59,12 @@ public struct QueryableOptions: OptionSet, Sendable {
     /// ``PresenceObservationQueryable`` types.
     public static let constantRegion = QueryableOptions(rawValue: 1 << 1)
 
+    /// By default, any error that occurs can be accessed using ``Query/Wrapper/error``
+    /// and is otherwise ignored.
+    /// With this option, errors that happen while accessing the
+    /// database terminate the app with a fatal error.
+    public static let assertNoFailure = QueryableOptions(rawValue: 1 << 2)
+    
     /// The default options.
     public static let `default`: QueryableOptions = []
 }

Sources/GRDBQuery/Queryable+DatabaseContext/ValueObservationQueryable.swift

@@ -68,10 +68,24 @@ extension TopLevelDatabaseReader {
                     .eraseToAnyPublisher()
             }
         }
+        .assertNoFailure(if: queryableOptions.contains(.assertNoFailure))
         .eraseToAnyPublisher()
     }
 }
 
+
+extension Publisher {
+    func assertNoFailure(if condition: Bool) -> AnyPublisher<Output, Failure> {
+        if !condition {
+            self.eraseToAnyPublisher()
+        } else {
+            self.assertNoFailure()
+                .setFailureType(to: Failure.self)
+                .eraseToAnyPublisher()
+        }
+    }
+}
+
 #if DEBUG
 import SwiftUI