Fix Dynamic Topic Subscriptions (#4767)

* check for sync status

* check for chainstart

Co-authored-by: prylabs-bulldozer[bot] <58059840+prylabs-bulldozer[bot]@users.noreply.github.com>
This commit is contained in:
Nishant Das
2020-02-08 06:49:18 +08:00
committed by GitHub
parent f16a71f178
commit efd27c7b2b

View File

@@ -211,6 +211,9 @@ func (r *Service) subscribeDynamic(topicFormat string, determineSubsLen func() i
stateSub.Unsubscribe()
return
case <-stateChannel:
if r.chainStarted && r.initialSync.Syncing() {
continue
}
// Update topic count.
wantedSubs := determineSubsLen()
// Resize as appropriate.