diff --git a/core/commands/pubsub.go b/core/commands/pubsub.go index 6f9dde58b..3df73939c 100644 --- a/core/commands/pubsub.go +++ b/core/commands/pubsub.go @@ -105,14 +105,16 @@ To use, the daemon must be run with '--enable-pubsub-experiment'. discover, _, _ := req.Option("discover").Bool() if discover { - blk := blocks.NewBlock([]byte("floodsub:" + topic)) - cid, err := n.Blocks.AddObject(blk) - if err != nil { - log.Error("pubsub discovery: ", err) - return - } + go func() { + blk := blocks.NewBlock([]byte("floodsub:" + topic)) + cid, err := n.Blocks.AddObject(blk) + if err != nil { + log.Error("pubsub discovery: ", err) + return + } - connectToPubSubPeers(req.Context(), n, cid) + connectToPubSubPeers(req.Context(), n, cid) + }() } }, Marshalers: cmds.MarshalerMap{