in src/Microsoft.Azure.WebJobs.Extensions.Kafka/Listeners/Scaler/KafkaGenericTopicScaler.cs [180:197]
private static bool IsTrueForLast(IList<KafkaTriggerMetrics> samples, int count, Func<KafkaTriggerMetrics, KafkaTriggerMetrics, bool> predicate)
{
if (samples.Count < count)
{
return false;
}
// Walks through the list from left to right starting at len(samples) - count.
for (int i = samples.Count - count; i < samples.Count - 1; i++)
{
if (!predicate(samples[i], samples[i + 1]))
{
return false;
}
}
return true;
}