From 5c6eba20e7ca9738debb66254b9c0c998a798255 Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Fri, 11 Dec 2020 00:32:29 +0300 Subject: [PATCH] codec: fix noop codec Signed-off-by: Vasiliy Tolstov --- codec/noop.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/codec/noop.go b/codec/noop.go index c232c087..02a0e12f 100644 --- a/codec/noop.go +++ b/codec/noop.go @@ -102,10 +102,10 @@ func (c *noopCodec) Marshal(v interface{}) ([]byte, error) { } func (c *noopCodec) Unmarshal(d []byte, v interface{}) error { + var err error if v == nil { return nil } - switch ve := v.(type) { case string: ve = string(d) @@ -119,6 +119,9 @@ func (c *noopCodec) Unmarshal(d []byte, v interface{}) error { ve.Data = d case *Message: ve.Body = d + default: + err = ErrInvalidMessage } - return ErrInvalidMessage + + return err }