mirror of
https://github.com/opencloud-eu/opencloud.git
synced 2026-05-07 12:01:27 -05:00
Jörn Friedrich Dreyer
5ed57cc09a
* bump dependencies Signed-off-by: Jörn Friedrich Dreyer <jfd@butonic.de> * bump reva and add config options Signed-off-by: Jörn Friedrich Dreyer <jfd@butonic.de> --------- Signed-off-by: Jörn Friedrich Dreyer <jfd@butonic.de>
36 lines
559 B
Go
36 lines
559 B
Go
package client
|
|
|
|
import (
|
|
"go-micro.dev/v4/codec"
|
|
"go-micro.dev/v4/transport"
|
|
)
|
|
|
|
type rpcResponse struct {
|
|
socket transport.Socket
|
|
codec codec.Codec
|
|
header map[string]string
|
|
body []byte
|
|
}
|
|
|
|
func (r *rpcResponse) Codec() codec.Reader {
|
|
return r.codec
|
|
}
|
|
|
|
func (r *rpcResponse) Header() map[string]string {
|
|
return r.header
|
|
}
|
|
|
|
func (r *rpcResponse) Read() ([]byte, error) {
|
|
var msg transport.Message
|
|
|
|
if err := r.socket.Recv(&msg); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// set internals
|
|
r.header = msg.Header
|
|
r.body = msg.Body
|
|
|
|
return msg.Body, nil
|
|
}
|