28 references to ResourceWatcher
Aspire.Hosting.Tests (28)
Dcp\DcpExecutorTests.cs (28)
1795() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null,
1951appExecutor.ResourceWatcher.TerminalLogFlushTimeout = TimeSpan.FromMilliseconds(100);
2033appExecutor.ResourceWatcher.TerminalLogFlushTimeout = TimeSpan.FromMilliseconds(100);
2052() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null,
2142Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name));
2155Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name));
2216() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is not null,
2218var firstLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name);
2223Assert.Null(appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name));
2332() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
2334var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2357() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
2359var currentLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2374Assert.Same(currentLogStreamTask, appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName));
2488() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
2490var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2513() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
2515var currentLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2517Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
2524Assert.Same(currentLogStreamTask, appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName));
2525Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
2532Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
2790appExecutor.ResourceWatcher.BeforeLogBatchDeliveryAsync = async resourceUid =>
2819() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
2821var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2849() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
2851var replacementLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2872appExecutor.ResourceWatcher.BeforeLogBatchDeliveryAsync = null;