fix tests

examples/Elastic.Channels.Continuous/Program.cs

@@ -1,4 +1,5 @@
-// Licensed to Elasticsearch B.V under one or more agreements. // Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
+// Licensed to Elasticsearch B.V under one or more agreements.
+// Elasticsearch B.V licenses this file to you under the Apache 2.0 License.
 // See the LICENSE file in the project root for more information
 
 using System.Threading.Channels;

src/Elastic.Channels/BufferedChannelBase.cs

@@ -424,9 +424,9 @@ async Task<bool> AsyncSlowPath(IOutboundBuffer<TEvent> b)
 	/// <inheritdoc cref="object.ToString"/>>
 	public override string ToString()
 	{
+		if (DiagnosticsListener == null) return base.ToString();
 		var sb = new StringBuilder();
-		if (DiagnosticsListener != null)
-			sb.AppendLine(DiagnosticsListener.ToString());
+		sb.AppendLine(DiagnosticsListener.ToString());
 		sb.AppendLine($"{nameof(InflightEvents)}: {InflightEvents:N0}");
 		sb.AppendLine($"{nameof(BufferOptions.InboundBufferMaxSize)}: {BufferOptions.InboundBufferMaxSize:N0}");
 		sb.AppendLine($"{nameof(BatchExportOperations)}: {BatchExportOperations:N0}");

tests/Elastic.Channels.Tests/BehaviorTests.cs

@@ -153,13 +153,13 @@ Task StartChannel(int taskNumber)
 	[Fact] public async Task SlowlyPushEvents()
 	{
 		int totalEvents = 50_000_000, maxInFlight = totalEvents / 5, bufferSize = maxInFlight / 10;
-		var expectedSentBuffers = totalEvents / bufferSize;
+		var expectedSentBuffers = totalEvents / 10_000;
 		var bufferOptions = new BufferOptions
 		{
 			WaitHandle = new CountdownEvent(expectedSentBuffers),
 			InboundBufferMaxSize = maxInFlight,
 			OutboundBufferMaxSize = 10_000,
-			OutboundBufferMaxLifetime = TimeSpan.FromMilliseconds(100)
+			OutboundBufferMaxLifetime = TimeSpan.FromMilliseconds(1000)
 		};
 		using var channel = new DiagnosticsBufferedChannel(bufferOptions, name: $"Slow push channel");
 		await Task.Delay(TimeSpan.FromMilliseconds(200));
@@ -175,7 +175,7 @@ [Fact] public async Task SlowlyPushEvents()
 			}
 		}, TaskCreationOptions.LongRunning);
 		// wait for some work to have progressed
-		bufferOptions.WaitHandle.Wait(TimeSpan.FromMilliseconds(500));
+		bufferOptions.WaitHandle.Wait(TimeSpan.FromMilliseconds(2000));
 		//Ensure we written to the channel but not enough to satisfy OutboundBufferMaxSize
 		written.Should().BeGreaterThan(0).And.BeLessThan(10_000);
 		//even though OutboundBufferMaxSize was not hit we should still observe an invocation to Export()