up
This commit is contained in:
@ -22,6 +22,7 @@ type TCPClient struct {
|
||||
LogWriter *bufio.Writer
|
||||
Reader *bufio.Reader
|
||||
Writer *bufio.Writer
|
||||
Scanner *bufio.Scanner
|
||||
Conn *net.TCPConn
|
||||
TCPServer TCPServer
|
||||
MsgChan chan string
|
||||
@ -130,9 +131,11 @@ func (c *TCPClient) SetFilters() {
|
||||
func (c *TCPClient) ReadLine() {
|
||||
|
||||
for {
|
||||
|
||||
message, err := c.Reader.ReadString('\n')
|
||||
message, _ = strings.CutSuffix(message, "\n")
|
||||
message, _ = strings.CutSuffix(message, "\r")
|
||||
|
||||
if err != nil {
|
||||
Log.Errorf("Error reading message: %s", err)
|
||||
c.Conn.Close()
|
||||
|
Reference in New Issue
Block a user