committed by
Mark Paluch
parent
723db60ce1
commit
e9d44256c6
@@ -453,7 +453,7 @@ public class ReactiveTransactionIntegrationTests {
|
||||
TransactionalOperator transactionalOperator = TransactionalOperator.create(manager,
|
||||
new DefaultTransactionDefinition());
|
||||
|
||||
return Flux.merge(operations.save(new EventLog(new ObjectId(), "beforeConvert")), //
|
||||
return Flux.concat(operations.save(new EventLog(new ObjectId(), "beforeConvert")), //
|
||||
operations.save(new EventLog(new ObjectId(), "afterConvert")), //
|
||||
operations.save(new EventLog(new ObjectId(), "beforeInsert")), //
|
||||
operations.save(person), //
|
||||
|
||||
Reference in New Issue
Block a user