in src/Elastic.Channels/Diagnostics/NoopBufferedChannel.cs [64:74]
protected override async Task<NoopResponse> ExportAsync(ArraySegment<NoopEvent> buffer, CancellationToken ctx = default)
{
Interlocked.Increment(ref _exportedBuffers);
if (!Options.TrackConcurrency) return new NoopResponse();
var max = Interlocked.Increment(ref _currentMax);
await Task.Delay(TimeSpan.FromMilliseconds(100), ctx).ConfigureAwait(false);
Interlocked.Decrement(ref _currentMax);
if (max > ObservedConcurrency) ObservedConcurrency = max;
return new NoopResponse();
}