Method Writer

IceFireDB-PubSub/pkg/ppubsub/pubsubStore.go:262–273

()

}

func (cr *PubSub) Writer() {
	for {
		msg := <-cr.Inbound
		for key, item := range pss.writer[cr.TopicName] {
			err := router.WriteBulkStrings(item, []string{"message", cr.TopicName, msg.Message})
			if err != nil {
				fmt.Println("write err key:", key)
				continue
			}
		}
	}
}

func (cr *PubSub) printPeer() {
	ticker := time.NewTicker(1 * time.Second)