mirror of
https://github.com/status-im/go-waku.git
synced 2025-01-12 23:04:45 +00:00
parent
826c7fb924
commit
6f1280e704
@ -286,8 +286,8 @@ func (w *WakuRelay) Publish(ctx context.Context, message *pb.WakuMessage, opts .
|
|||||||
return nil, errors.New("not enough peers to publish")
|
return nil, errors.New("not enough peers to publish")
|
||||||
}
|
}
|
||||||
|
|
||||||
w.topicsMutex.RLock()
|
w.topicsMutex.Lock()
|
||||||
defer w.topicsMutex.RUnlock()
|
defer w.topicsMutex.Unlock()
|
||||||
|
|
||||||
pubSubTopic, err := w.upsertTopic(params.pubsubTopic)
|
pubSubTopic, err := w.upsertTopic(params.pubsubTopic)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user