diff --git a/codec.go b/codec.go index 2f32a0b..44f16d5 100644 --- a/codec.go +++ b/codec.go @@ -172,7 +172,7 @@ func (g *grpcCodec) Write(m *codec.Message, v interface{}) error { return g.s.SendMsg(v) } // write the body using the framing codec - return g.s.SendMsg(&bytes.Frame{m.Body}) + return g.s.SendMsg(&bytes.Frame{Data: m.Body}) } func (g *grpcCodec) Close() error {