diff --git a/client/client_handlers.go b/client/client_handlers.go index 5363c5b..071a8db 100644 --- a/client/client_handlers.go +++ b/client/client_handlers.go @@ -8,6 +8,7 @@ import ( "git.loafle.net/commons_go/rpc" "git.loafle.net/commons_go/rpc/protocol" + cuc "git.loafle.net/commons_go/util/context" ) type ClientHandlers struct { diff --git a/client/rwc/socket/client_rwc_handlers.go b/client/rwc/socket/client_rwc_handlers.go index f900e97..f8d3dd1 100644 --- a/client/rwc/socket/client_rwc_handlers.go +++ b/client/rwc/socket/client_rwc_handlers.go @@ -1,7 +1,6 @@ package socket import ( - "fmt" "io" "git.loafle.net/commons_go/logging" @@ -18,12 +17,6 @@ func New(address string) client.ClientReadWriteCloseHandler { type ClientReadWriteCloseHandlers struct { client.ClientReadWriteCloseHandlers - - Address string -} - -func (crwch *ClientReadWriteCloseHandlers) Connect(clientCTX client.ClientContext) (interface{}, error) { - return nil, fmt.Errorf("RPC Client RWC Handler: ClientHandlers method[Connect] is not implement") } func (crwch *ClientReadWriteCloseHandlers) ReadResponse(clientCTX client.ClientContext, codec protocol.ClientCodec, conn interface{}) (protocol.ClientResponseCodec, error) { diff --git a/client/rwc/websocket/fasthttp/client_rwc_handlers.go b/client/rwc/websocket/fasthttp/client_rwc_handlers.go index 2561f7b..dade377 100644 --- a/client/rwc/websocket/fasthttp/client_rwc_handlers.go +++ b/client/rwc/websocket/fasthttp/client_rwc_handlers.go @@ -1,7 +1,6 @@ package fasthttp import ( - "fmt" "io" "github.com/gorilla/websocket" @@ -19,10 +18,6 @@ type ClientReadWriteCloseHandlers struct { client.ClientReadWriteCloseHandlers } -func (crwch *ClientReadWriteCloseHandlers) Connect(clientCTX client.ClientContext) (interface{}, error) { - return nil, fmt.Errorf("RPC Client RWC Handler: ClientHandlers method[Connect] is not implement") -} - func (crwch *ClientReadWriteCloseHandlers) ReadResponse(clientCTX client.ClientContext, codec protocol.ClientCodec, conn interface{}) (protocol.ClientResponseCodec, error) { if nil == conn { return nil, io.EOF