File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -554,7 +554,11 @@ where
554
554
// Table sync workers signal when they complete initial data copying and are ready
555
555
// to transition to continuous replication mode. Guard the branch so it stays
556
556
// dormant if no signal receiver was provided.
557
- _ = force_syncing_tables_rx. as_mut( ) . unwrap( ) . changed( ) , if force_syncing_tables_rx. is_some( ) => {
557
+ _ = async {
558
+ if let Some ( rx) = force_syncing_tables_rx. as_mut( ) {
559
+ let _ = rx. changed( ) . await ;
560
+ }
561
+ } , if force_syncing_tables_rx. is_some( ) => {
558
562
// Table state transitions can only occur at transaction boundaries to maintain consistency.
559
563
// If we're in the middle of processing a transaction (remote_final_lsn is set),
560
564
// we defer the sync processing until the current transaction completes.
You can’t perform that action at this time.
0 commit comments