Versions in this module Expand all Collapse all v1 v1.4.1 Mar 1, 2023 Changes in this version + var ErrTimeout = errors.New("timeout") + func NewWriterAndReader(s p2p.Stream) (Writer, Reader) + type Message = proto.Message + func ReadMessages(r io.Reader, newMessage func() Message) (m []Message, err error) + type Reader struct + func NewReader(r io.Reader) Reader + func (r Reader) ReadMsgWithContext(ctx context.Context, msg proto.Message) error + type Writer struct + func NewWriter(w io.Writer) Writer + func (w Writer) WriteMsgWithContext(ctx context.Context, msg proto.Message) error