28 references to ResourceWatcher
Aspire.Hosting.Tests (28)
Dcp\DcpExecutorTests.cs (28)
2243() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null,
2399appExecutor.ResourceWatcher.TerminalLogFlushTimeout = TimeSpan.FromMilliseconds(100);
2481appExecutor.ResourceWatcher.TerminalLogFlushTimeout = TimeSpan.FromMilliseconds(100);
2500() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null,
2590Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name));
2603Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name));
2664() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is not null,
2666var firstLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name);
2671Assert.Null(appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name));
2780() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
2782var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2805() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
2807var currentLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2822Assert.Same(currentLogStreamTask, appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName));
2936() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
2938var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2961() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
2963var currentLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
2965Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
2972Assert.Same(currentLogStreamTask, appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName));
2973Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
2980Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
3351appExecutor.ResourceWatcher.BeforeLogBatchDeliveryAsync = async resourceUid =>
3380() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
3382var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3410() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
3412var replacementLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3433appExecutor.ResourceWatcher.BeforeLogBatchDeliveryAsync = null;