31 lines
1010 B
Go
31 lines
1010 B
Go
|
package client
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
|
||
|
|
"git.loafle.net/commons_go/rpc/protocol"
|
||
|
|
)
|
||
|
|
|
||
|
|
type ClientReadWriteCloseHandlers struct {
|
||
|
|
}
|
||
|
|
|
||
|
|
func (crwch *ClientReadWriteCloseHandlers) Connect() (interface{}, error) {
|
||
|
|
return nil, fmt.Errorf("RPC Client RWC Handler: ClientHandlers method[Connect] is not implement")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (crwch *ClientReadWriteCloseHandlers) ReadResponse(clientCTX ClientContext, codec protocol.ClientCodec, conn interface{}) (protocol.ClientResponseCodec, error) {
|
||
|
|
return nil, fmt.Errorf("RPC Client RWC Handler: ClientHandlers method[ReadResponse] is not implement")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (crwch *ClientReadWriteCloseHandlers) WriteRequest(clientCTX ClientContext, codec protocol.ClientCodec, conn interface{}, method string, params interface{}, id interface{}) error {
|
||
|
|
return fmt.Errorf("RPC Client RWC Handler: ClientHandlers method[WriteRequest] is not implement")
|
||
|
|
}
|
||
|
|
|
||
|
|
func (crwch *ClientReadWriteCloseHandlers) Disconnect(conn interface{}) {
|
||
|
|
// no op
|
||
|
|
}
|
||
|
|
|
||
|
|
func (crwch *ClientReadWriteCloseHandlers) Validate() {
|
||
|
|
|
||
|
|
}
|