diff options
Diffstat (limited to 'internal/ior.go')
| -rw-r--r-- | internal/ior.go | 17 |
1 files changed, 2 insertions, 15 deletions
diff --git a/internal/ior.go b/internal/ior.go index 1010445..d88f0e3 100644 --- a/internal/ior.go +++ b/internal/ior.go @@ -244,14 +244,6 @@ func tuiTraceStarterFromRunTrace( bindings.SetEventStreamSource(streamSource) bindings.SetLiveTrie(liveTrie) } - streamEvents := make(chan eventstream.StreamEvent, appconfig.DefaultChannelBufferSize) - - go func() { - for ev := range streamEvents { - streamBuf.Push(ev) - } - }() - startedCh := make(chan struct{}) errCh := make(chan error, 1) @@ -264,7 +256,7 @@ func tuiTraceStarterFromRunTrace( } row := eventstream.NewStreamEvent(streamSeq.Next(), ep) engine.Ingest(ep) - streamEvents <- row + streamBuf.Push(row) if recorder != nil { if err := recorder.Record(row, filterEpoch); err != nil { recorderWarningOnce.Do(func() { @@ -280,14 +272,9 @@ func tuiTraceStarterFromRunTrace( ep.Recycle() } el.warningCb = func(message string) { - // Drop warning notifications if the stream channel is saturated. - select { - case streamEvents <- eventstream.NewWarningEvent(streamSeq.Next(), message): - default: - } + streamBuf.Push(eventstream.NewWarningEvent(streamSeq.Next(), message)) } }) - close(streamEvents) errCh <- err close(errCh) }() |