Skip to content
Closed
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 2 additions & 1 deletion src/Runtime/CollectionTask.cs
Original file line number Diff line number Diff line change
Expand Up @@ -141,6 +141,7 @@ internal async Task ConsumeSearchResults()
d.Properties.Add("collected", true);
}
await _outputChannel.Writer.WriteAsync(processed);
watch.Reset();
}
catch (Exception e)
{
Expand All @@ -152,4 +153,4 @@ internal async Task ConsumeSearchResults()
log.LogDebug("Consumer task on thread {id} completed", Thread.CurrentThread.ManagedThreadId);
}
}
}
}
Loading