aboutsummaryrefslogtreecommitdiff
path: root/elegoo.go
diff options
context:
space:
mode:
Diffstat (limited to 'elegoo.go')
-rw-r--r--elegoo.go8
1 files changed, 8 insertions, 0 deletions
diff --git a/elegoo.go b/elegoo.go
index 50ed37f..c2d19c7 100644
--- a/elegoo.go
+++ b/elegoo.go
@@ -19,6 +19,14 @@ func Send(w io.Writer, pb proto.Message) error {
return err
}
+func RecvR(r io.Reader, pb proto.Message) error {
+ block, err := bufio.NewReader(r).ReadBytes(0)
+ if err != nil {
+ return err
+ }
+ return proto.NewBuffer(cobs.Decode(block)).DecodeMessage(pb)
+}
+
func Recv(buf *bufio.Reader, pb proto.Message) error {
block, err := buf.ReadBytes(0)
if err != nil {