This commit is contained in:
nquidox 2026-02-20 16:20:19 +03:00
parent 4c5b1c7030
commit 23b439f0aa

View file

@ -9,11 +9,11 @@ type Publisher interface {
Push(data []byte) error Push(data []byte) error
} }
type PubHandler struct { type pubHandler struct {
client *Client client *Client
} }
func (p *PubHandler) Push(data []byte) error { func (p *pubHandler) Push(data []byte) error {
p.client.mutex.Lock() p.client.mutex.Lock()
if !p.client.isReady { if !p.client.isReady {
p.client.mutex.Unlock() p.client.mutex.Unlock()