From bb4daedd4ceb4e4637fd0ba1af8aa53b5afe0924 Mon Sep 17 00:00:00 2001 From: Darien Raymond Date: Mon, 27 Mar 2017 08:56:16 +0200 Subject: [PATCH] allow 0 timeout --- transport/ray/direct.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/transport/ray/direct.go b/transport/ray/direct.go index df773d5f..02a64b4b 100644 --- a/transport/ray/direct.go +++ b/transport/ray/direct.go @@ -91,6 +91,10 @@ func (v *Stream) ReadTimeout(timeout time.Duration) (*buf.Buffer, error) { case b := <-v.buffer: return b, nil default: + if timeout == 0 { + return nil, ErrReadTimeout + } + select { case <-v.ctx.Done(): return nil, io.ErrClosedPipe