|
@@ -60,13 +60,13 @@ func (s *Socket) read() {
|
|
|
//defer log.Println("work close...")
|
|
//defer log.Println("work close...")
|
|
|
// контекст
|
|
// контекст
|
|
|
s.ctx, s.cancel = context.WithCancel(context.Background())
|
|
s.ctx, s.cancel = context.WithCancel(context.Background())
|
|
|
- defer func() {
|
|
|
|
|
- s.cancel()
|
|
|
|
|
- s.conn.Close()
|
|
|
|
|
- }()
|
|
|
|
|
// создаем канал для обработки входящих сообщений
|
|
// создаем канал для обработки входящих сообщений
|
|
|
chIn := s.exec()
|
|
chIn := s.exec()
|
|
|
go func() {
|
|
go func() {
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ s.cancel()
|
|
|
|
|
+ s.conn.Close()
|
|
|
|
|
+ }()
|
|
|
for {
|
|
for {
|
|
|
// Read message from server
|
|
// Read message from server
|
|
|
mType, r, err := s.conn.NextReader()
|
|
mType, r, err := s.conn.NextReader()
|
