cleanup
This commit is contained in:
@@ -55,8 +55,6 @@ func NewProducer(rawURL string) (*Producer, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (p *Producer) Start() error {
|
func (p *Producer) Start() error {
|
||||||
defer p.client.Close()
|
|
||||||
|
|
||||||
for {
|
for {
|
||||||
_ = p.client.SetDeadline(time.Now().Add(core.ConnDeadline))
|
_ = p.client.SetDeadline(time.Now().Add(core.ConnDeadline))
|
||||||
pkt, err := p.client.ReadPacket()
|
pkt, err := p.client.ReadPacket()
|
||||||
|
|||||||
Reference in New Issue
Block a user