From 57a353e92f6bf7c93fc9bcee792e9dea772675d2 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Sun, 16 Apr 2017 21:31:16 +0200 Subject: [PATCH] return EOF on context done --- transport/ray/direct.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/transport/ray/direct.go b/transport/ray/direct.go index 743852aeb..c2a472fa8 100644 --- a/transport/ray/direct.go +++ b/transport/ray/direct.go @@ -88,7 +88,7 @@ func (s *Stream) Read() (buf.MultiBuffer, error) { select { case <-s.ctx.Done(): - return nil, io.ErrClosedPipe + return nil, io.EOF case <-s.wakeup: } } @@ -107,7 +107,7 @@ func (s *Stream) ReadTimeout(timeout time.Duration) (buf.MultiBuffer, error) { select { case <-s.ctx.Done(): - return nil, io.ErrClosedPipe + return nil, io.EOF case <-time.After(timeout): return nil, buf.ErrReadTimeout case <-s.wakeup: @@ -166,5 +166,3 @@ func (s *Stream) CloseError() { s.wakeUp() s.access.Unlock() } - -func (v *Stream) Release() {}