SetSender 注入当前 session 的 Sender。传 nil 时下一轮 push 会被跳过。 一般在 Config.OnConnected 回调里调用: cfg.OnConnected = func(ctx context.Context, s nodeagent.Sender) { pusher.SetSender(s) }
(s Sender)
| 70 | // pusher.SetSender(s) |
| 71 | // } |
| 72 | func (p *UsagePusher) SetSender(s Sender) { |
| 73 | p.mu.Lock() |
| 74 | p.sender = s |
| 75 | p.mu.Unlock() |
| 76 | } |
| 77 | |
| 78 | func (p *UsagePusher) currentSender() Sender { |
| 79 | p.mu.Lock() |
no outgoing calls