File tree Expand file tree Collapse file tree 1 file changed +6
-5
lines changed
disintegrate-postgres/src Expand file tree Collapse file tree 1 file changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -212,12 +212,13 @@ where
212212 CriteriaBuilder :: new( & query. change_origin( version) ) . build( )
213213 ) )
214214 . fetch_one ( & mut * tx)
215- . await ? {
215+ . await ?
216+ {
216217 return Err ( Error :: Concurrency ) ;
217218 }
218219
219- let mut sequence_insert = InsertEventsBuilder :: new ( & events, & self . serde ) ;
220- let event_ids: Vec < PgEventId > = sequence_insert
220+ let mut insert = InsertEventsBuilder :: new ( & events, & self . serde ) ;
221+ let event_ids: Vec < PgEventId > = insert
221222 . build ( )
222223 . fetch_all ( & mut * tx)
223224 . await ?
@@ -256,8 +257,8 @@ where
256257 {
257258 let mut tx = self . pool . begin ( ) . await ?;
258259
259- let mut sequence_insert = InsertEventsBuilder :: new ( & events, & self . serde ) ;
260- let event_ids: Vec < PgEventId > = sequence_insert
260+ let mut insert = InsertEventsBuilder :: new ( & events, & self . serde ) ;
261+ let event_ids: Vec < PgEventId > = insert
261262 . build ( )
262263 . fetch_all ( & mut * tx)
263264 . await ?
You can’t perform that action at this time.
0 commit comments