From 23363506f58b68d2e87c9a7f85cc72083e49b513 Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Sat, 6 Jan 2018 16:40:35 +1100 Subject: [PATCH] Reader: Changing responsiveness should wake blocked reads --- reader.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/reader.go b/reader.go index 76c39e96..1be3b0ad 100644 --- a/reader.go +++ b/reader.go @@ -50,11 +50,13 @@ var _ io.ReadCloser = &reader{} // soon as they can when the underlying chunks become available. func (r *reader) SetResponsive() { r.responsive = true + r.t.cl.event.Broadcast() } // Disable responsive mode. TODO: Remove? func (r *reader) SetNonResponsive() { r.responsive = false + r.t.cl.event.Broadcast() } // Configure the number of bytes ahead of a read that should also be