|
@@ -51,7 +51,7 @@ func (w *BroadcastWriter) Write(p []byte) (n int, err error) {
|
|
for {
|
|
for {
|
|
line, err := w.buf.ReadString('\n')
|
|
line, err := w.buf.ReadString('\n')
|
|
if err != nil {
|
|
if err != nil {
|
|
- w.buf.Write([]byte(line))
|
|
|
|
|
|
+ w.buf.WriteString(line)
|
|
break
|
|
break
|
|
}
|
|
}
|
|
for stream, writers := range w.streams {
|
|
for stream, writers := range w.streams {
|