diff options
Diffstat (limited to 'internal/io/fs/chunkedreader.go')
| -rw-r--r-- | internal/io/fs/chunkedreader.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/io/fs/chunkedreader.go b/internal/io/fs/chunkedreader.go index b7c90d4..5f16c12 100644 --- a/internal/io/fs/chunkedreader.go +++ b/internal/io/fs/chunkedreader.go @@ -60,11 +60,11 @@ func (cr *ChunkedReader) ProcessLines(ctx context.Context, rawLines chan *bytes. return nil } else { // In tailing mode - EOF means wait and try again - // This mimics the original behavior of sleeping 100ms on EOF + // Use shorter polling interval for better responsiveness to rapid writes select { case <-ctx.Done(): return ctx.Err() - case <-time.After(100 * time.Millisecond): + case <-time.After(10 * time.Millisecond): // Continue reading after brief pause continue } |