Skip to content
Snippets Groups Projects
Unverified Commit 215618be authored by capossele's avatar capossele
Browse files

:recycle: Fix event closure

parent 6d497d51
No related branches found
No related tags found
No related merge requests found
...@@ -62,11 +62,13 @@ func run(_ *node.Plugin) { ...@@ -62,11 +62,13 @@ func run(_ *node.Plugin) {
if err := daemon.BackgroundWorker(PluginName, func(shutdownSignal <-chan struct{}) { if err := daemon.BackgroundWorker(PluginName, func(shutdownSignal <-chan struct{}) {
fpctest.Voter().Events().Finalized.Attach(events.NewClosure(onFinalized)) onFinalizedClosure := events.NewClosure(onFinalized)
defer fpctest.Voter().Events().Finalized.Detach(events.NewClosure(onFinalized)) fpctest.Voter().Events().Finalized.Attach(onFinalizedClosure)
defer fpctest.Voter().Events().Finalized.Detach(onFinalizedClosure)
fpctest.Voter().Events().RoundExecuted.Attach(events.NewClosure(onRoundExecuted)) onRoundExecutedClosure := events.NewClosure(onRoundExecuted)
defer fpctest.Voter().Events().RoundExecuted.Detach(events.NewClosure(onRoundExecuted)) fpctest.Voter().Events().RoundExecuted.Attach(onRoundExecutedClosure)
defer fpctest.Voter().Events().RoundExecuted.Detach(onRoundExecutedClosure)
ticker := time.NewTicker(reportIntervalSec * time.Second) ticker := time.NewTicker(reportIntervalSec * time.Second)
defer ticker.Stop() defer ticker.Stop()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment