From e6f870bda71ac2e9b2d1e6d4bec311f0782ddece Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Sun, 20 Dec 2020 23:53:29 +0300 Subject: [PATCH] codec: fix interface Signed-off-by: Vasiliy Tolstov --- codec/codec.go | 6 +++--- codec/noop.go | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/codec/codec.go b/codec/codec.go index dad14d4a..1052d8e2 100644 --- a/codec/codec.go +++ b/codec/codec.go @@ -38,9 +38,9 @@ type MessageType int // connection. ReadBody may be called with a nil argument to force the // body to be read and discarded. type Codec interface { - ReadHeader(io.ReadWriter, *Message, MessageType) error - ReadBody(io.ReadWriter, interface{}) error - Write(io.ReadWriter, *Message, interface{}) error + ReadHeader(io.Reader, *Message, MessageType) error + ReadBody(io.Reader, interface{}) error + Write(io.Writer, *Message, interface{}) error Marshal(interface{}) ([]byte, error) Unmarshal([]byte, interface{}) error String() string diff --git a/codec/noop.go b/codec/noop.go index 02a0e12f..129c89bd 100644 --- a/codec/noop.go +++ b/codec/noop.go @@ -13,11 +13,11 @@ type Frame struct { Data []byte } -func (c *noopCodec) ReadHeader(conn io.ReadWriter, m *Message, t MessageType) error { +func (c *noopCodec) ReadHeader(conn io.Reader, m *Message, t MessageType) error { return nil } -func (c *noopCodec) ReadBody(conn io.ReadWriter, b interface{}) error { +func (c *noopCodec) ReadBody(conn io.Reader, b interface{}) error { // read bytes buf, err := ioutil.ReadAll(conn) if err != nil { @@ -46,7 +46,7 @@ func (c *noopCodec) ReadBody(conn io.ReadWriter, b interface{}) error { return nil } -func (c *noopCodec) Write(conn io.ReadWriter, m *Message, b interface{}) error { +func (c *noopCodec) Write(conn io.Writer, m *Message, b interface{}) error { if b == nil { return nil }