From aa1de9acde321f692550cf81624b8c8372dcb950 Mon Sep 17 00:00:00 2001 From: Steven Allen Date: Tue, 1 Sep 2020 18:23:14 -0700 Subject: [PATCH] feat: update to new stream interfaces This change updates to the latest stream interfaces. --- p2p/muxer/yamux/stream.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/p2p/muxer/yamux/stream.go b/p2p/muxer/yamux/stream.go index d5b865b777..f51b721b3b 100644 --- a/p2p/muxer/yamux/stream.go +++ b/p2p/muxer/yamux/stream.go @@ -36,6 +36,14 @@ func (s *stream) Reset() error { return s.yamux().Reset() } +func (s *stream) CloseRead() error { + return s.yamux().CloseRead() +} + +func (s *stream) CloseWrite() error { + return s.yamux().CloseWrite() +} + func (s *stream) SetDeadline(t time.Time) error { return s.yamux().SetDeadline(t) }