mirror of
https://github.com/JohnEstropia/CoreStore.git
synced 2026-04-17 22:49:41 +02:00
Optimize ListSnapshot collection implementation
This commit is contained in:
@@ -78,7 +78,7 @@ extension Internals {
|
|||||||
|
|
||||||
var numberOfItems: Int {
|
var numberOfItems: Int {
|
||||||
|
|
||||||
return self.structure.allItemIDs.count
|
return self.structure.allItemsCount
|
||||||
}
|
}
|
||||||
|
|
||||||
var numberOfSections: Int {
|
var numberOfSections: Int {
|
||||||
@@ -106,6 +106,59 @@ extension Internals {
|
|||||||
return self.itemIdentifiers(inSection: identifier).count
|
return self.itemIdentifiers(inSection: identifier).count
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func itemIdentifier(atAllItemsIndex index: Int) -> NSManagedObjectID? {
|
||||||
|
|
||||||
|
guard index >= 0 else {
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
var remainingIndex = index
|
||||||
|
for section in self.structure.sections {
|
||||||
|
|
||||||
|
let elements = section.elements
|
||||||
|
let sectionCount = elements.count
|
||||||
|
if remainingIndex < sectionCount {
|
||||||
|
|
||||||
|
return elements[remainingIndex].differenceIdentifier
|
||||||
|
}
|
||||||
|
|
||||||
|
remainingIndex -= sectionCount
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func itemIdentifiers(atAllItemsBounds bounds: Range<Int>) -> [NSManagedObjectID] {
|
||||||
|
|
||||||
|
var remainingIndex = bounds.lowerBound
|
||||||
|
var itemIdentifiers: [NSManagedObjectID] = []
|
||||||
|
for section in self.structure.sections {
|
||||||
|
|
||||||
|
let elements = section.elements
|
||||||
|
let sectionCount = elements.count
|
||||||
|
if remainingIndex < sectionCount {
|
||||||
|
|
||||||
|
itemIdentifiers.append(
|
||||||
|
contentsOf: elements[remainingIndex..<min(sectionCount, bounds.count)]
|
||||||
|
.map({ $0.differenceIdentifier })
|
||||||
|
)
|
||||||
|
}
|
||||||
|
else if !itemIdentifiers.isEmpty {
|
||||||
|
|
||||||
|
itemIdentifiers.append(
|
||||||
|
contentsOf: elements.prefix(bounds.count - itemIdentifiers.count)
|
||||||
|
.map({ $0.differenceIdentifier })
|
||||||
|
)
|
||||||
|
}
|
||||||
|
if itemIdentifiers.count >= bounds.count {
|
||||||
|
|
||||||
|
return itemIdentifiers
|
||||||
|
}
|
||||||
|
|
||||||
|
remainingIndex -= sectionCount
|
||||||
|
}
|
||||||
|
return itemIdentifiers
|
||||||
|
}
|
||||||
|
|
||||||
func itemIdentifiers(inSection identifier: String) -> [NSManagedObjectID] {
|
func itemIdentifiers(inSection identifier: String) -> [NSManagedObjectID] {
|
||||||
|
|
||||||
return self.structure.items(in: identifier)
|
return self.structure.items(in: identifier)
|
||||||
@@ -332,6 +385,14 @@ extension Internals {
|
|||||||
return self.sections.map({ $0.differenceIdentifier })
|
return self.sections.map({ $0.differenceIdentifier })
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var allItemsCount: Int {
|
||||||
|
|
||||||
|
return self.sections.reduce(into: 0) { (result, section) in
|
||||||
|
|
||||||
|
result += section.elements.count
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
var allItemIDs: [NSManagedObjectID] {
|
var allItemIDs: [NSManagedObjectID] {
|
||||||
|
|
||||||
return self.sections.lazy.flatMap({ $0.elements }).map({ $0.differenceIdentifier })
|
return self.sections.lazy.flatMap({ $0.elements }).map({ $0.differenceIdentifier })
|
||||||
|
|||||||
@@ -71,7 +71,7 @@ public struct ListSnapshot<O: DynamicObject>: RandomAccessCollection, Hashable {
|
|||||||
public subscript(index: Index) -> ObjectPublisher<O> {
|
public subscript(index: Index) -> ObjectPublisher<O> {
|
||||||
|
|
||||||
let context = self.context!
|
let context = self.context!
|
||||||
let itemID = self.diffableSnapshot.itemIdentifiers[index]
|
let itemID = self.diffableSnapshot.itemIdentifier(atAllItemsIndex: index)!
|
||||||
return context.objectPublisher(objectID: itemID)
|
return context.objectPublisher(objectID: itemID)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -83,16 +83,13 @@ public struct ListSnapshot<O: DynamicObject>: RandomAccessCollection, Hashable {
|
|||||||
*/
|
*/
|
||||||
public subscript(safeIndex index: Index) -> ObjectPublisher<O>? {
|
public subscript(safeIndex index: Index) -> ObjectPublisher<O>? {
|
||||||
|
|
||||||
guard let context = self.context else {
|
guard
|
||||||
|
let context = self.context,
|
||||||
|
let itemID = self.diffableSnapshot.itemIdentifier(atAllItemsIndex: index)
|
||||||
|
else {
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
let itemIDs = self.diffableSnapshot.itemIdentifiers
|
|
||||||
guard itemIDs.indices.contains(index) else {
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
let itemID = itemIDs[index]
|
|
||||||
return context.objectPublisher(objectID: itemID)
|
return context.objectPublisher(objectID: itemID)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -603,14 +600,69 @@ public struct ListSnapshot<O: DynamicObject>: RandomAccessCollection, Hashable {
|
|||||||
|
|
||||||
public var startIndex: Index {
|
public var startIndex: Index {
|
||||||
|
|
||||||
return self.diffableSnapshot.itemIdentifiers.startIndex
|
return 0
|
||||||
}
|
}
|
||||||
|
|
||||||
public var endIndex: Index {
|
public var endIndex: Index {
|
||||||
|
|
||||||
return self.diffableSnapshot.itemIdentifiers.endIndex
|
return self.diffableSnapshot.numberOfItems
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public func index(after i: Index) -> Index {
|
||||||
|
|
||||||
|
return i + 1
|
||||||
|
}
|
||||||
|
|
||||||
|
public func formIndex(after i: inout Index) {
|
||||||
|
|
||||||
|
return i += 1
|
||||||
|
}
|
||||||
|
|
||||||
|
public func index(before i: Index) -> Index {
|
||||||
|
|
||||||
|
return i - 1
|
||||||
|
}
|
||||||
|
|
||||||
|
public func formIndex(before i: inout Index) {
|
||||||
|
|
||||||
|
return i -= 1
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
// MARK: BidirectionalCollection
|
||||||
|
|
||||||
|
public func index(_ i: Index, offsetBy distance: Int) -> Index {
|
||||||
|
|
||||||
|
return i + distance
|
||||||
|
}
|
||||||
|
|
||||||
|
public func index(_ i: Index, offsetBy distance: Int, limitedBy limit: Int) -> Index? {
|
||||||
|
|
||||||
|
let length = limit - i
|
||||||
|
if distance > 0
|
||||||
|
? length >= 0 && length < distance
|
||||||
|
: length <= 0 && length > distance {
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return i + distance
|
||||||
|
}
|
||||||
|
|
||||||
|
public func distance(from start: Index, to end: Index) -> Int {
|
||||||
|
|
||||||
|
return end - start
|
||||||
|
}
|
||||||
|
|
||||||
|
public subscript(bounds: Range<Index>) -> ArraySlice<Element> {
|
||||||
|
|
||||||
|
guard let context = self.context else {
|
||||||
|
|
||||||
|
return .init()
|
||||||
|
}
|
||||||
|
let itemIDs = self.diffableSnapshot.itemIdentifiers(atAllItemsBounds: bounds)
|
||||||
|
return ArraySlice(itemIDs.map(context.objectPublisher(objectID:)))
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
// MARK: Sequence
|
// MARK: Sequence
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user