28 references to ResourceWatcher
Aspire.Hosting.Tests (28)
Dcp\DcpExecutorTests.cs (28)
2010() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null,
2166appExecutor.ResourceWatcher.TerminalLogFlushTimeout = TimeSpan.FromMilliseconds(100);
2248appExecutor.ResourceWatcher.TerminalLogFlushTimeout = TimeSpan.FromMilliseconds(100);
2267() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null,
2357Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name));
2370Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name));
2431() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is not null,
2433var firstLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name);
2438Assert.Null(appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name));
2547() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
2549var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2572() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
2574var currentLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2589Assert.Same(currentLogStreamTask, appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName));
2703() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
2705var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2728() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
2730var currentLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2732Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
2739Assert.Same(currentLogStreamTask, appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName));
2740Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
2747Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
3118appExecutor.ResourceWatcher.BeforeLogBatchDeliveryAsync = async resourceUid =>
3147() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
3149var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3177() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
3179var replacementLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3200appExecutor.ResourceWatcher.BeforeLogBatchDeliveryAsync = null;