Reader: Changing responsiveness should wake blocked reads

diff --git a/reader.go b/reader.go
index 76c39e968307f08af9728c5ff050427f639ed46f..1be3b0ade37faeadbd7bb4f53177f1c54be83ca4 100644 (file)
--- 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