Use send instead of feed on terminal events channel (#23631)

Potentially fixes a bug where tasks are not marked as finished.

Release Notes:

- N/A
This commit is contained in:
Michael Sloan 2025-01-24 15:32:22 -07:00 committed by GitHub
parent d2c55cbe3d
commit ec5d02d5c2
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -493,7 +493,7 @@ impl TerminalBuilder {
while let Some(event) = events_rx.next().await { while let Some(event) = events_rx.next().await {
// Process the first event immediately to reduce latency // Process the first event immediately to reduce latency
accumulated_events_tx accumulated_events_tx
.feed(EventOrAccumulator::Event(event)) .send(EventOrAccumulator::Event(event))
.await?; .await?;
'outer: loop { 'outer: loop {
let start_time = Instant::now(); let start_time = Instant::now();
@ -520,7 +520,7 @@ impl TerminalBuilder {
} }
} }
accumulated_events_tx accumulated_events_tx
.feed(EventOrAccumulator::Accumulator(event_accumulator)) .send(EventOrAccumulator::Accumulator(event_accumulator))
.await?; .await?;
} }
} }