peer api call 크래시 방지
This commit is contained in:
@ -119,7 +119,15 @@ func (hc *WebsocketPeerApiBroker[T]) AddHandler(receiver WebsocketPeerApiHandler
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (hc *WebsocketPeerApiBroker[T]) Call(recv T, funcname string, r io.Reader) (any, error) {
|
func (hc *WebsocketPeerApiBroker[T]) Call(recv T, funcname string, r io.Reader) (v any, e error) {
|
||||||
|
defer func() {
|
||||||
|
r := recover()
|
||||||
|
if r != nil {
|
||||||
|
logger.Error(r)
|
||||||
|
e = fmt.Errorf("%v", r)
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
|
||||||
if found := hc.methods[funcname]; found != nil {
|
if found := hc.methods[funcname]; found != nil {
|
||||||
return found(recv, r)
|
return found(recv, r)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user