Function InitPubSub

IceFireDB-PubSub/pkg/ppubsub/pubsubStore.go:26–28

(ctx context.Context, p2p *p2p.P2P)

const defaulttopic = "pubsub"

func InitPubSub(ctx context.Context, p2p *p2p.P2P) {
	pss = NewPubsubStore(ctx, p2p)
}

type pubsubStore struct {
	sync.RWMutex // synchronize access to shared variables