|
|
@@ -82,6 +82,7 @@ func (s *SocketServer) SendMessage(req rest.IRequestOut) (<-chan *rest.RequestSt
|
|
|
|
|
|
func (s *SocketServer) work() {
|
|
|
defer log.Println("AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA")
|
|
|
+loop:
|
|
|
for {
|
|
|
select {
|
|
|
case <-s.socket.Context().Done():
|
|
|
@@ -112,7 +113,7 @@ func (s *SocketServer) work() {
|
|
|
log.Println("socket send error", err)
|
|
|
}
|
|
|
reqOut.RClose()
|
|
|
- return
|
|
|
+ continue loop
|
|
|
}
|
|
|
}
|
|
|
reqOut = command.Execute(reqIn)
|
