@@ -55,46 +55,23 @@ class StatusTests {
55
55
56
56
@Test
57
57
fun testProviderTransitionsToReconcilingOnContextSet () = runTest {
58
- assertEquals(OpenFeatureStatus .NotReady , OpenFeatureAPI .getStatus())
58
+ waitAssert {
59
+ assertEquals(OpenFeatureStatus .NotReady , OpenFeatureAPI .getStatus())
60
+ }
59
61
val statuses = mutableListOf<OpenFeatureStatus >()
60
62
val job = launch {
61
63
OpenFeatureAPI .statusFlow.collect {
62
64
statuses.add(it)
63
65
}
64
66
}
65
67
OpenFeatureAPI .setProviderAndWait(DoSomethingProvider ())
66
- testScheduler.advanceUntilIdle()
68
+ waitAssert { assertEquals( OpenFeatureStatus . Ready , OpenFeatureAPI .getStatus()) }
67
69
OpenFeatureAPI .setEvaluationContextAndWait(ImmutableContext (" some value" ))
68
- testScheduler.advanceUntilIdle()
69
- waitAssert {
70
- assertEquals(4 , statuses.size)
71
- }
72
-
73
- OpenFeatureAPI .setEvaluationContextAndWait(ImmutableContext (" some other value" ))
74
- testScheduler.advanceUntilIdle()
70
+ waitAssert { assertEquals(OpenFeatureStatus .Reconciling , OpenFeatureAPI .getStatus()) }
75
71
waitAssert {
76
- assertEquals(6 , statuses.size)
77
- }
78
-
79
- OpenFeatureAPI .shutdown()
80
- testScheduler.advanceUntilIdle()
81
- waitAssert {
82
- assertEquals(OpenFeatureStatus .NotReady , OpenFeatureAPI .getStatus())
72
+ assertEquals(OpenFeatureStatus .Ready , OpenFeatureAPI .getStatus())
83
73
}
84
74
job.cancelAndJoin()
85
-
86
- assertEquals(
87
- listOf (
88
- OpenFeatureStatus .NotReady ,
89
- OpenFeatureStatus .Ready ,
90
- OpenFeatureStatus .Reconciling ,
91
- OpenFeatureStatus .Ready ,
92
- OpenFeatureStatus .Reconciling ,
93
- OpenFeatureStatus .Ready ,
94
- OpenFeatureStatus .NotReady
95
- ),
96
- statuses
97
- )
98
75
}
99
76
}
100
77
0 commit comments