@@ -71,7 +71,7 @@ where E == E.EntityBindingType.EntityType {
71
71
var result = true
72
72
73
73
try store. obx_runInTransaction ( writable: false , { swiftTx in
74
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
74
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
75
75
76
76
for currId in ids {
77
77
if try ! cursor. contains ( currId. value) {
@@ -114,7 +114,7 @@ extension Box {
114
114
var writtenId : Id = 0
115
115
116
116
try store. obx_runInTransaction ( writable: true , { swiftTx in
117
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
117
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
118
118
119
119
writtenId = try putOne ( entity, binding: binding, flatBuffer: flatBuffer, mode: mode, cursor: cursor)
120
120
try binding. postPut ( fromEntity: entity, id: writtenId, store: store)
@@ -144,7 +144,7 @@ extension Box {
144
144
var writtenId : Id = 0
145
145
146
146
try store. obx_runInTransaction ( writable: true , { swiftTx in
147
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
147
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
148
148
149
149
writtenId = try putOne ( entity, binding: binding, flatBuffer: flatBuffer, mode: mode, cursor: cursor)
150
150
try binding. postPut ( fromEntity: entity, id: writtenId, store: store)
@@ -194,7 +194,7 @@ extension Box {
194
194
let flatBuffer = FlatBufferBuilder . dequeue ( )
195
195
defer { FlatBufferBuilder . return ( flatBuffer) }
196
196
197
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
197
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
198
198
199
199
initializedCount = 0
200
200
for entity in entities {
@@ -229,7 +229,7 @@ extension Box {
229
229
let flatBuffer = FlatBufferBuilder . dequeue ( )
230
230
defer { FlatBufferBuilder . return ( flatBuffer) }
231
231
232
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
232
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
233
233
234
234
for entity in entities {
235
235
let writtenId = try putOne ( entity, binding: binding, flatBuffer: flatBuffer,
@@ -251,7 +251,7 @@ extension Box {
251
251
let flatBuffer = FlatBufferBuilder . dequeue ( )
252
252
defer { FlatBufferBuilder . return ( flatBuffer) }
253
253
254
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
254
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
255
255
256
256
for entity in entities {
257
257
let writtenId = try putOne ( entity, binding: binding, flatBuffer: flatBuffer,
@@ -273,7 +273,7 @@ extension Box {
273
273
let flatBuffer = FlatBufferBuilder . dequeue ( )
274
274
defer { FlatBufferBuilder . return ( flatBuffer) }
275
275
276
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
276
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
277
277
278
278
for entity in entities {
279
279
let writtenId = try putOne ( entity, binding: binding, flatBuffer: flatBuffer,
@@ -302,7 +302,7 @@ extension Box {
302
302
let flatBuffer = FlatBufferBuilder . dequeue ( )
303
303
defer { FlatBufferBuilder . return ( flatBuffer) }
304
304
305
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
305
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
306
306
307
307
for entityIndex in 0 ..< entities. count {
308
308
let newEntity = entities [ entityIndex]
@@ -566,7 +566,7 @@ extension Box {
566
566
/// abort the loop. Exceptions thrown by the closure are re-thrown.
567
567
public func visit( writable: Bool = false , visitor: ( EntityType ) throws -> Bool ) throws {
568
568
try store. obx_runInTransaction ( writable: writable, { swiftTx in
569
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
569
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
570
570
try withoutActuallyEscaping ( visitor) { callback in
571
571
let context : InstanceVisitorBase = InstanceVisitor ( type: EntityType . self, store: store,
572
572
visitor: callback)
@@ -625,7 +625,7 @@ extension Box {
625
625
public func visit< C: Collection > ( writable: Bool = false , _ ids: C , in visitor: ( EntityType ? ) throws -> Bool ) throws
626
626
where C. Element == EntityType . EntityBindingType . IdType {
627
627
try store. obx_runInTransaction ( writable: writable, { swiftTx in
628
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
628
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
629
629
try withoutActuallyEscaping ( visitor) { callback in
630
630
let context = InstanceVisitor ( type: EntityType . self, store: store,
631
631
visitor: callback)
@@ -697,7 +697,7 @@ extension Box {
697
697
var result : UInt64 = 0
698
698
699
699
try store. obx_runInTransaction ( writable: true , { swiftTx in
700
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
700
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
701
701
702
702
for currEntity in entities {
703
703
if try cursor. remove ( currEntity) {
@@ -715,7 +715,7 @@ extension Box {
715
715
var result : UInt64 = 0
716
716
717
717
try store. obx_runInTransaction ( writable: true , { swiftTx in
718
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
718
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
719
719
720
720
for currEntity in entities {
721
721
if try cursor. remove ( currEntity) {
@@ -733,7 +733,7 @@ extension Box {
733
733
var result : UInt64 = 0
734
734
735
735
try store. obx_runInTransaction ( writable: true , { swiftTx in
736
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
736
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
737
737
738
738
for currEntity in entities {
739
739
if try cursor. remove ( currEntity) {
@@ -763,7 +763,7 @@ extension Box {
763
763
public func remove( _ entityIDs: [ Id ] ) throws -> UInt64 {
764
764
var result : UInt64 = 0
765
765
try store. obx_runInTransaction ( writable: true , { swiftTx in
766
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
766
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
767
767
for currId in entityIDs {
768
768
if try cursor. remove ( currId. value) {
769
769
result += 1
@@ -795,7 +795,7 @@ extension Box {
795
795
var result : UInt64 = 0
796
796
797
797
try store. obx_runInTransaction ( writable: true , { swiftTx in
798
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
798
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
799
799
for currId in ids {
800
800
if try cursor. remove ( currId. value) {
801
801
result += 1
@@ -832,7 +832,7 @@ extension Box {
832
832
public func remove( _ entityIDs: [ EntityId < EntityType > ] ) throws -> UInt64 {
833
833
var result : UInt64 = 0
834
834
try store. obx_runInTransaction ( writable: true , { swiftTx in
835
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
835
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
836
836
for currId in entityIDs {
837
837
if try cursor. remove ( currId. value) {
838
838
result += 1
@@ -864,7 +864,7 @@ extension Box {
864
864
var result : UInt64 = 0
865
865
866
866
try store. obx_runInTransaction ( writable: true , { swiftTx in
867
- let cursor = Cursor < EntityType > ( transaction: swiftTx)
867
+ let cursor = try Cursor < EntityType > ( transaction: swiftTx)
868
868
for currId in entityIDs {
869
869
if try cursor. remove ( currId. value) {
870
870
result += 1
0 commit comments