Sleep when no input is available while streaming

axiomhq · Aug 19, 2024 · c4e9464 · c4e9464
1 parent c471443
commit c4e9464
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/internal/cmd/ingest/ingest.go b/internal/cmd/ingest/ingest.go
@@ -382,6 +382,7 @@ func ingestEvery(ctx context.Context, client *axiom.Client, r io.Reader, opts *o
 					_ = pw.CloseWithError(ctx.Err())
 					return
 				default:
+					time.Sleep(time.Millisecond)
 				}
 
 				if !scanner.Scan() {
@@ -415,6 +416,8 @@ func ingestEvery(ctx context.Context, client *axiom.Client, r io.Reader, opts *o
 			case <-done:
 				_ = pw.Close()
 				return
+			default:
+				time.Sleep(time.Millisecond)
 			}
 		}
 	}()