aboutsummaryrefslogtreecommitdiff
path: root/elegoo.go
diff options
context:
space:
mode:
authorDimitri Sokolyuk <demon@dim13.org>2017-12-13 00:54:35 +0100
committerDimitri Sokolyuk <demon@dim13.org>2017-12-13 00:54:35 +0100
commit156a9a2271d47934a97ff00f33b8a61c8a49f125 (patch)
tree2f6a7b132dee1ddaae00484a398064f6b0a6603f /elegoo.go
parent49b9dbaba204e6a69465e422f76debac540e75b7 (diff)
rename back
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 {