@@ -952,7 +952,7 @@ defmodule Electric.Shapes.ConsumerTest do
         %Commit{lsn: lsn1}
       ]
 
-      assert :ok = ShapeLogCollector.store_transaction(txn, ctx.producer)
+      assert :ok = ShapeLogCollector.handle_operations(txn, ctx.producer)
 
       assert_receive {:flush_boundary_updated, 300}, 1_000
Original file line number	Diff line number	Diff line change
`@@ -952,7 +952,7 @@ defmodule Electric.Shapes.ConsumerTest do`
`952`	`952`	`%Commit{lsn: lsn1}`
`953`	`953`	`]`
`954`	`954`
`955`		`- assert :ok = ShapeLogCollector.store_transaction(txn, ctx.producer)`
	`955`	`+ assert :ok = ShapeLogCollector.handle_operations(txn, ctx.producer)`
`956`	`956`
`957`	`957`	`assert_receive {:flush_boundary_updated, 300}, 1_000`
`958`	`958`