Versions in this module Expand all Collapse all v0 v0.7.1 Sep 14, 2022 v0.7.0 Jul 8, 2022 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