Commit 5769a8d2 authored by Adrian Sutton's avatar Adrian Sutton

op-node: Fix race condition closing gossip handler.

parent a298160f
......@@ -601,7 +601,6 @@ func MakeSubscriber(log log.Logger, msgHandler MessageHandler) TopicSubscriber {
}
func LogTopicEvents(ctx context.Context, log log.Logger, evHandler *pubsub.TopicEventHandler) {
defer evHandler.Cancel()
for {
ev, err := evHandler.NextPeerEvent(ctx)
if err != nil {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment