Merge pull request #4402 from keks/fix/pubsub-flush

core/commands/pubsub.go: flush output before iterating over received messages

core/commands/pubsub.go

@@ -5,6 +5,7 @@ import (
 	"encoding/binary"
 	"fmt"
 	"io"
+	"net/http"
 	"sync"
 	"time"
 
@@ -109,6 +110,10 @@ This command outputs data in the following encodings:
 			}()
 		}
 
+		if f, ok := res.(http.Flusher); ok {
+			f.Flush()
+		}
+
 		for {
 			msg, err := sub.Next(req.Context())
 			if err == io.EOF || err == context.Canceled {