Skip to content

Commit cc61125

Browse files
committed
Remove stress test
1 parent 08ab93c commit cc61125

File tree

1 file changed

+16
-17
lines changed

1 file changed

+16
-17
lines changed

tests/KubernetesClient.Tests/SharedInformerTests.cs

Lines changed: 16 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -129,24 +129,23 @@ public static IEnumerable<object[]> GetTestScenarios()
129129
[MemberData(nameof(GetTestScenarios))]
130130
public async Task FirstSubscriber(string description, ScheduledEvent<TestResource>[] scenario, ResourceEvent<TestResource>[] expected)
131131
{
132-
for (int i = 0; i < 1000; i++)
133-
{
134-
_log.LogInformation("===============================================================================");
135-
_log.LogInformation(description);
136-
var cache = new SimpleCache<int, TestResource>();
137-
var masterInformer = Substitute.For<IInformer<TestResource>>();
138-
masterInformer.GetResource(ResourceStreamType.ListWatch).Returns(scenario.ToTestObservable());
139-
var sharedInformer = new SharedInformer<int, TestResource>(masterInformer, _log, x => x.Key, cache);
140-
141-
var observable = sharedInformer
142-
.GetResource(ResourceStreamType.ListWatch)
143-
.TimeoutIfNotDebugging()
144-
.ToList();
145-
var results = await observable;
132+
133+
_log.LogInformation("===============================================================================");
134+
_log.LogInformation(description);
135+
var cache = new SimpleCache<int, TestResource>();
136+
var masterInformer = Substitute.For<IInformer<TestResource>>();
137+
masterInformer.GetResource(ResourceStreamType.ListWatch).Returns(scenario.ToTestObservable());
138+
var sharedInformer = new SharedInformer<int, TestResource>(masterInformer, _log, x => x.Key, cache);
146139

147-
results.Should().NotBeEmpty();
148-
results.Should().BeEquivalentTo(expected);
149-
}
140+
var observable = sharedInformer
141+
.GetResource(ResourceStreamType.ListWatch)
142+
.TimeoutIfNotDebugging()
143+
.ToList();
144+
var results = await observable;
145+
146+
results.Should().NotBeEmpty();
147+
results.Should().BeEquivalentTo(expected);
148+
150149
}
151150

152151
[Fact]

0 commit comments

Comments
 (0)