Sleep when no input is available while streaming

lukasmalkmus · lukasmalkmus · commit c4e9464479bc · 2024-08-19T12:19:30.000+02:00
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)
 			}
 		}
 	}()

Original file line number	Diff line number	Diff line change
`@@ -382,6 +382,7 @@ func ingestEvery(ctx context.Context, client axiom.Client, r io.Reader, opts o`
`382`	`382`	`_ = pw.CloseWithError(ctx.Err())`
`383`	`383`	`return`
`384`	`384`	`default:`
	`385`	`+ time.Sleep(time.Millisecond)`
`385`	`386`	`}`
`386`	`387`
`387`	`388`	`if !scanner.Scan() {`
`@@ -415,6 +416,8 @@ func ingestEvery(ctx context.Context, client axiom.Client, r io.Reader, opts o`
`415`	`416`	`case <-done:`
`416`	`417`	`_ = pw.Close()`
`417`	`418`	`return`
	`419`	`+ default:`
	`420`	`+ time.Sleep(time.Millisecond)`
`418`	`421`	`}`
`419`	`422`	`}`
`420`	`423`	`}()`