@@ -99,7 +99,7 @@ extension CoreDataRepository {
9999 let readContext = context. childContext ( )
100100 return AsyncStream { continuation in
101101 let provider : ReadSubscription < Model >
102- switch Self . getObjectId ( fromUrl : url, context : readContext ) {
102+ switch readContext . objectId ( from : url) {
103103 case let . success( objectId) :
104104 provider = ReadSubscription < Model > (
105105 objectId: objectId,
@@ -126,7 +126,7 @@ extension CoreDataRepository {
126126 let readContext = context. childContext ( )
127127 return AsyncThrowingStream { continuation in
128128 let provider : ReadThrowingSubscription < Model >
129- switch Self . getObjectId ( fromUrl : url, context : readContext ) {
129+ switch readContext . objectId ( from : url) {
130130 case let . success( objectId) :
131131 provider = ReadThrowingSubscription < Model > (
132132 objectId: objectId,
@@ -145,14 +145,4 @@ extension CoreDataRepository {
145145 }
146146 }
147147 }
148-
149- private static func getObjectId(
150- fromUrl url: URL ,
151- context: NSManagedObjectContext
152- ) -> Result < NSManagedObjectID , CoreDataError > {
153- guard let objectId = context. persistentStoreCoordinator? . managedObjectID ( forURIRepresentation: url) else {
154- return Result . failure ( . failedToGetObjectIdFromUrl( url) )
155- }
156- return . success( objectId)
157- }
158148}
0 commit comments