diff --git a/beacon-chain/sync/subscriber.go b/beacon-chain/sync/subscriber.go index ba1785c53549..3c42d9ca1790 100644 --- a/beacon-chain/sync/subscriber.go +++ b/beacon-chain/sync/subscriber.go @@ -698,10 +698,10 @@ func (s *Service) subscribeDynamicWithSyncSubnets( // Retrieve the current slot. currentSlot := s.cfg.clock.CurrentSlot() - // Subscribe to the sync subnets. - s.subscribeToSyncSubnets(topicFormat, digest, genesisValidatorsRoot, genesisTime, subscriptions, currentSlot, validate, handle) - go func() { + // Subscribe to the sync subnets. + s.subscribeToSyncSubnets(topicFormat, digest, genesisValidatorsRoot, genesisTime, subscriptions, currentSlot, validate, handle) + for { select { case currentSlot := <-ticker.C():