aa
This commit is contained in:
@@ -376,12 +376,13 @@ func HandleTcpMessages() {
|
|||||||
for {
|
for {
|
||||||
select {
|
select {
|
||||||
case obj, _ := <-printMsgChan:
|
case obj, _ := <-printMsgChan:
|
||||||
if _, ok := obj.(*model.PrintMsg); !ok {
|
if _, ok := obj.(*model.PrintMsg); ok {
|
||||||
|
continue
|
||||||
|
} else {
|
||||||
if data, ok2 := obj.(string); ok2 {
|
if data, ok2 := obj.(string); ok2 {
|
||||||
changePrintMsg(data)
|
changePrintMsg(data)
|
||||||
break flag
|
break flag
|
||||||
}
|
}
|
||||||
continue
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user