fix cr suggestion

Change-Id: Ic1c90803c4fe8a43d1192a65ca2d331364a50eab
This commit is contained in:
debug-LiXiwen 2022-08-24 19:54:35 +08:00
parent b209349e7f
commit 083c5aa790

View File

@ -1302,10 +1302,10 @@ func (this *Migrator) executeWriteFuncs() error {
func (this *Migrator) drainApplierEventQueue() error {
for {
this.throttler.throttle(nil)
select {
case eventStruct := <-this.applyEventsQueue:
{
this.throttler.throttle(nil)
if err := this.onApplyEventStruct(eventStruct); err != nil {
return err
}