diff --git a/servlet/rpc-servlet.go b/servlet/rpc-servlet.go index 82f2b46..f3d7011 100644 --- a/servlet/rpc-servlet.go +++ b/servlet/rpc-servlet.go @@ -96,6 +96,7 @@ func (s *RPCServlets) handleRPCWrite(stopChan <-chan struct{}, writeChan chan<- buf, err = s.RPCServerCodec.NewNotification(noti.Method, noti.Params) if nil != err { logging.Logger().Error(err) + break } writeChan <- buf