(conn io.ReadCloser, partialReads bool, out chan<- *Packet)
| 532 | } |
| 533 | |
| 534 | func parseTo(conn io.ReadCloser, partialReads bool, out chan<- *Packet) { |
| 535 | defer conn.Close() |
| 536 | |
| 537 | parser := NewParser(conn, partialReads) |
| 538 | for { |
| 539 | p, more := parser.Next() |
| 540 | if p != nil { |
| 541 | out <- p |
| 542 | } |
| 543 | |
| 544 | if !more { |
| 545 | break |
| 546 | } |
| 547 | } |
| 548 | } |
| 549 | |
| 550 | func udpListener() { |
| 551 | address, _ := net.ResolveUDPAddr("udp", *serviceAddress) |