28 references to ResourceWatcher
Aspire.Hosting.Tests (28)
Dcp\DcpExecutorTests.cs (28)
2729() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null,
2885appExecutor.ResourceWatcher.TerminalLogFlushTimeout = TimeSpan.FromMilliseconds(100);
2967appExecutor.ResourceWatcher.TerminalLogFlushTimeout = TimeSpan.FromMilliseconds(100);
2986() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null,
3076Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name));
3089Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name));
3150() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is not null,
3152var firstLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name);
3157Assert.Null(appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name));
3266() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
3268var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3291() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
3293var currentLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3308Assert.Same(currentLogStreamTask, appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName));
3422() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
3424var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3447() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
3449var currentLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3451Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
3458Assert.Same(currentLogStreamTask, appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName));
3459Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
3466Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(dcpResourceName));
3837appExecutor.ResourceWatcher.BeforeLogBatchDeliveryAsync = async resourceUid =>
3866() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is not null,
3868var previousLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3896() => appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName) is { } task && task != previousLogStreamTask,
3898var replacementLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(dcpResourceName);
3919appExecutor.ResourceWatcher.BeforeLogBatchDeliveryAsync = null;