ing
This commit is contained in:
parent
64216d22c4
commit
6cf3533828
10
socket.go
10
socket.go
|
@ -42,12 +42,12 @@ func (s *Socket) WaitRequest() (*SocketConn, error) {
|
|||
return nil, err
|
||||
}
|
||||
|
||||
sc := retainSocketConn()
|
||||
sc.s = s
|
||||
sc.MessageType = mt
|
||||
sc.r = r
|
||||
s.sc = retainSocketConn()
|
||||
s.sc.s = s
|
||||
s.sc.MessageType = mt
|
||||
s.sc.r = r
|
||||
|
||||
return sc, nil
|
||||
return s.sc, nil
|
||||
}
|
||||
|
||||
func (s *Socket) NextWriter(messageType int) (io.WriteCloser, error) {
|
||||
|
|
Loading…
Reference in New Issue
Block a user