@@ -55,44 +55,22 @@ class StatusTests {
5555
5656 @Test
5757 fun testProviderTransitionsToReconcilingOnContextSet () = runTest {
58- assertEquals(OpenFeatureStatus .NotReady , OpenFeatureAPI .getStatus())
58+ waitAssert {
59+ assertEquals(OpenFeatureStatus .NotReady , OpenFeatureAPI .getStatus())
60+ }
5961 val statuses = mutableListOf<OpenFeatureStatus >()
6062 val job = launch {
6163 OpenFeatureAPI .statusFlow.collect {
6264 statuses.add(it)
6365 }
6466 }
6567 OpenFeatureAPI .setProviderAndWait(DoSomethingProvider ())
66- testScheduler.advanceUntilIdle()
68+ waitAssert { assertEquals( OpenFeatureStatus . Ready , OpenFeatureAPI .getStatus()) }
6769 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()
75- waitAssert {
76- assertEquals(6 , statuses.size)
77- }
78-
79- OpenFeatureAPI .shutdown()
80- testScheduler.advanceUntilIdle()
70+ waitAssert { assertEquals(OpenFeatureStatus .Reconciling , OpenFeatureAPI .getStatus()) }
8171 waitAssert {
82- assertEquals(OpenFeatureStatus .NotReady , OpenFeatureAPI .getStatus())
72+ assertEquals(OpenFeatureStatus .Ready , OpenFeatureAPI .getStatus())
8373 }
84- assertEquals(
85- listOf (
86- OpenFeatureStatus .NotReady ,
87- OpenFeatureStatus .Ready ,
88- OpenFeatureStatus .Reconciling ,
89- OpenFeatureStatus .Ready ,
90- OpenFeatureStatus .Reconciling ,
91- OpenFeatureStatus .Ready ,
92- OpenFeatureStatus .NotReady
93- ),
94- statuses
95- )
9674 job.cancelAndJoin()
9775 }
9876}
0 commit comments