Explorar el Código

修复sse太小导致的断连问题

moki hace 2 semanas
padre
commit
a894f5150c
Se han modificado 1 ficheros con 1 adiciones y 0 borrados
  1. 1 0
      internal/monitor/monitor.go

+ 1 - 0
internal/monitor/monitor.go

@@ -120,6 +120,7 @@ func (m *Monitor) connectAndRead(ctx context.Context) error {
 	}()
 
 	scanner := bufio.NewScanner(resp.Body)
+	scanner.Buffer(make([]byte, 0, 1024*1024), 1024*1024)
 	for scanner.Scan() {
 		select {
 		case <-ctx.Done():