lotus/lib/cborrpc/rpc.go
2019-07-25 17:49:27 -07:00

24 lines
362 B
Go

package cborrpc
import (
"io"
cbor "github.com/ipfs/go-ipld-cbor"
)
const MessageSizeLimit = 1 << 20
func WriteCborRPC(w io.Writer, obj interface{}) error {
data, err := cbor.DumpObject(obj)
if err != nil {
return err
}
_, err = w.Write(data)
return err
}
func ReadCborRPC(r io.Reader, out interface{}) error {
return cbor.DecodeReader(r, out)
}