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
 	}