ing
This commit is contained in:
parent
33369b4422
commit
a356983559
|
@ -48,7 +48,7 @@ func (sh *RPCGatewayServletHandlers) Handshake(serverCTX cwf.ServerContext, ctx
|
|||
}
|
||||
|
||||
func (sh *RPCGatewayServletHandlers) SocketContext(serverCTX cwf.ServerContext) cwf.SocketContext {
|
||||
socketCTX := sh.SocketContext(serverCTX)
|
||||
socketCTX := sh.ServletHandlers.SocketContext(serverCTX)
|
||||
|
||||
return newServletContext(socketCTX)
|
||||
}
|
||||
|
@ -73,9 +73,9 @@ func (sh *RPCGatewayServletHandlers) Handle(soc cwf.Socket, stopChan <-chan stru
|
|||
|
||||
rpcDoneChan := make(chan error, 1)
|
||||
|
||||
// if err = rpcServlet.Start(soc.Context(), soc, rpcDoneChan); nil != err {
|
||||
// return
|
||||
// }
|
||||
if err = rpcServlet.Start(soc.Context(), soc, rpcDoneChan); nil != err {
|
||||
return
|
||||
}
|
||||
|
||||
select {
|
||||
case err = <-rpcDoneChan:
|
||||
|
|
Loading…
Reference in New Issue
Block a user