From 170438c0d0f1dc9d4721f9a0a29d0d632e8b755b Mon Sep 17 00:00:00 2001 From: crusader Date: Sat, 24 Mar 2018 02:32:44 +0900 Subject: [PATCH] ing --- client/rwc/socket/client_rwc_handlers.go | 4 ++-- client/rwc/websocket/fasthttp/client_rwc_handlers.go | 4 ++-- server/rwc/socket/servlet_rwc_handlers.go | 8 ++++---- server/rwc/websocket/fasthttp/servlet_rwc_handlers.go | 8 ++++---- 4 files changed, 12 insertions(+), 12 deletions(-) diff --git a/client/rwc/socket/client_rwc_handlers.go b/client/rwc/socket/client_rwc_handlers.go index 828f6b3..60e4e3d 100644 --- a/client/rwc/socket/client_rwc_handlers.go +++ b/client/rwc/socket/client_rwc_handlers.go @@ -37,7 +37,7 @@ func (crwch *ClientReadWriteCloseHandlers) ReadResponse(clientCTX client.ClientC return nil, rErr } - return codec.NewResponseB(buf) + return codec.NewResponse(buf) } func (crwch *ClientReadWriteCloseHandlers) WriteRequest(clientCTX client.ClientContext, codec protocol.ClientCodec, conn interface{}, method string, params []interface{}, id interface{}) error { @@ -47,7 +47,7 @@ func (crwch *ClientReadWriteCloseHandlers) WriteRequest(clientCTX client.ClientC ) soc := conn.(csc.Socket) - buf, wErr = codec.NewRequestB(method, params, id) + buf, wErr = codec.NewRequest(method, params, id) if nil != wErr { return wErr } diff --git a/client/rwc/websocket/fasthttp/client_rwc_handlers.go b/client/rwc/websocket/fasthttp/client_rwc_handlers.go index 3f93f88..67eb54d 100644 --- a/client/rwc/websocket/fasthttp/client_rwc_handlers.go +++ b/client/rwc/websocket/fasthttp/client_rwc_handlers.go @@ -38,7 +38,7 @@ func (crwch *ClientReadWriteCloseHandlers) ReadResponse(clientCTX client.ClientC return nil, err } - return codec.NewResponseB(buf) + return codec.NewResponse(buf) } func (crwch *ClientReadWriteCloseHandlers) WriteRequest(clientCTX client.ClientContext, codec protocol.ClientCodec, conn interface{}, method string, params []interface{}, id interface{}) error { @@ -48,7 +48,7 @@ func (crwch *ClientReadWriteCloseHandlers) WriteRequest(clientCTX client.ClientC ) soc := conn.(cwfc.Socket) - buf, wErr = codec.NewRequestB(method, params, id) + buf, wErr = codec.NewRequest(method, params, id) if nil != wErr { return wErr } diff --git a/server/rwc/socket/servlet_rwc_handlers.go b/server/rwc/socket/servlet_rwc_handlers.go index bf34278..039de26 100644 --- a/server/rwc/socket/servlet_rwc_handlers.go +++ b/server/rwc/socket/servlet_rwc_handlers.go @@ -26,7 +26,7 @@ func (srwch *ServletReadWriteCloseHandlers) ReadRequest(servletCTX rpc.ServletCo return nil, rErr } - return codec.NewRequestB(buf) + return codec.NewRequest(buf) } func (srwch *ServletReadWriteCloseHandlers) WriteResponse(servletCTX rpc.ServletContext, conn interface{}, reqCodec protocol.ServerRequestCodec, result interface{}, err error) error { @@ -37,9 +37,9 @@ func (srwch *ServletReadWriteCloseHandlers) WriteResponse(servletCTX rpc.Servlet soc := conn.(server.Socket) if nil != err { - buf, wErr = reqCodec.NewErrorB(500, err) + buf, wErr = reqCodec.NewError(500, err) } else { - buf, wErr = reqCodec.NewResponseB(result) + buf, wErr = reqCodec.NewResponse(result) } if nil != wErr { return wErr @@ -60,7 +60,7 @@ func (srwch *ServletReadWriteCloseHandlers) WriteNotification(servletCTX rpc.Ser ) soc := conn.(server.Socket) - buf, wErr = codec.NewNotificationB(method, params) + buf, wErr = codec.NewNotification(method, params) if nil != wErr { return wErr } diff --git a/server/rwc/websocket/fasthttp/servlet_rwc_handlers.go b/server/rwc/websocket/fasthttp/servlet_rwc_handlers.go index 439a5d6..ad9099a 100644 --- a/server/rwc/websocket/fasthttp/servlet_rwc_handlers.go +++ b/server/rwc/websocket/fasthttp/servlet_rwc_handlers.go @@ -28,7 +28,7 @@ func (srwch *ServletReadWriteCloseHandlers) ReadRequest(servletCTX rpc.ServletCo return nil, err } - return codec.NewRequestB(buf) + return codec.NewRequest(buf) } func (srwch *ServletReadWriteCloseHandlers) WriteResponse(servletCTX rpc.ServletContext, conn interface{}, requestCodec protocol.ServerRequestCodec, result interface{}, err error) error { @@ -43,9 +43,9 @@ func (srwch *ServletReadWriteCloseHandlers) WriteResponse(servletCTX rpc.Servlet soc := conn.(cwf.Socket) if nil != err { - buf, wErr = requestCodec.NewErrorB(500, err) + buf, wErr = requestCodec.NewError(500, err) } else { - buf, wErr = requestCodec.NewResponseB(result) + buf, wErr = requestCodec.NewResponse(result) } if nil != wErr { return wErr @@ -69,7 +69,7 @@ func (srwch *ServletReadWriteCloseHandlers) WriteNotification(servletCTX rpc.Ser ) soc := conn.(cwf.Socket) - buf, wErr = codec.NewNotificationB(method, params) + buf, wErr = codec.NewNotification(method, params) if nil != wErr { return wErr }