77
88import android .content .Context ;
99
10- import androidx .annotation .NonNull ;
1110import androidx .test .platform .app .InstrumentationRegistry ;
1211
1312import org .junit .After ;
3736import io .split .android .client .SplitClientConfig ;
3837import io .split .android .client .SplitFactory ;
3938import io .split .android .client .api .Key ;
40- import io .split .android .client .events .SdkEventListener ;
39+ import io .split .android .client .events .SplitEventListener ;
4140import io .split .android .client .events .SdkReadyMetadata ;
4241import io .split .android .client .events .SdkUpdateMetadata ;
4342import io .split .android .client .events .SplitEvent ;
4443import io .split .android .client .events .SplitEventTask ;
4544import io .split .android .client .network .HttpMethod ;
4645import io .split .android .client .storage .db .GeneralInfoEntity ;
47- import io .split .android .client .storage .db .MyLargeSegmentEntity ;
4846import io .split .android .client .storage .db .MySegmentEntity ;
4947import io .split .android .client .storage .db .SplitEntity ;
5048import io .split .android .client .storage .db .SplitRoomDatabase ;
@@ -246,7 +244,7 @@ public void sdkReadyListenerFiresWithMetadata() throws Exception {
246244 SplitClient client = factory .client (new Key ("key_1" ));
247245
248246 // And: a handler H is registered using addEventListener with onReady
249- client .addEventListener (new SdkEventListener () {
247+ client .addEventListener (new SplitEventListener () {
250248 @ Override
251249 public void onReady (SplitClient client , SdkReadyMetadata metadata ) {
252250 onReadyCount .incrementAndGet ();
@@ -297,7 +295,7 @@ public void sdkReadyListenerReplaysToLateSubscribers() throws Exception {
297295 AtomicReference <SdkReadyMetadata > receivedMetadata = new AtomicReference <>();
298296 CountDownLatch lateReadyLatch = new CountDownLatch (1 );
299297
300- fixture .client .addEventListener (new SdkEventListener () {
298+ fixture .client .addEventListener (new SplitEventListener () {
301299 @ Override
302300 public void onReady (SplitClient client , SdkReadyMetadata metadata ) {
303301 onReadyCount .incrementAndGet ();
@@ -342,7 +340,7 @@ public void sdkReadyViewListenerFiresOnMainThread() throws Exception {
342340 SplitClient client = factory .client (new Key ("key_1" ));
343341
344342 // And: a handler H is registered using addEventListener with onReadyView
345- client .addEventListener (new SdkEventListener () {
343+ client .addEventListener (new SplitEventListener () {
346344 @ Override
347345 public void onReadyView (SplitClient client , SdkReadyMetadata metadata ) {
348346 onReadyViewCount .incrementAndGet ();
@@ -488,7 +486,7 @@ public void sdkUpdateEmittedOnlyAfterSdkReady() throws Exception {
488486 CountDownLatch updateLatch = new CountDownLatch (1 );
489487
490488 // Register handlers BEFORE SDK_READY fires
491- fixture .client .addEventListener (new SdkEventListener () {
489+ fixture .client .addEventListener (new SplitEventListener () {
492490 @ Override
493491 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
494492 updateHandlerCount .incrementAndGet ();
@@ -546,7 +544,7 @@ public void sdkUpdateFiresOnAnyDataChangeEventAfterSdkReady() throws Exception {
546544 AtomicReference <SdkUpdateMetadata > lastMetadata = new AtomicReference <>();
547545 CountDownLatch updateLatch = new CountDownLatch (1 );
548546
549- fixture .client .addEventListener (new SdkEventListener () {
547+ fixture .client .addEventListener (new SplitEventListener () {
550548 @ Override
551549 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
552550 updateHandlerCount .incrementAndGet ();
@@ -591,7 +589,7 @@ public void sdkUpdateDoesNotReplayToLateSubscribers() throws Exception {
591589 AtomicReference <CountDownLatch > secondUpdateLatchRef = new AtomicReference <>(null );
592590
593591 // And: a handler H1 is registered for sdkUpdate
594- fixture .client .addEventListener (new SdkEventListener () {
592+ fixture .client .addEventListener (new SplitEventListener () {
595593 @ Override
596594 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
597595 handler1Count .incrementAndGet ();
@@ -620,7 +618,7 @@ public void onUpdate(SplitClient client, SdkUpdateMetadata metadata) {
620618 CountDownLatch secondUpdateLatch = new CountDownLatch (2 );
621619 secondUpdateLatchRef .set (secondUpdateLatch );
622620
623- fixture .client .addEventListener (new SdkEventListener () {
621+ fixture .client .addEventListener (new SplitEventListener () {
624622 @ Override
625623 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
626624 handler2Count .incrementAndGet ();
@@ -872,7 +870,7 @@ public void handlersInvokedSequentiallyErrorsIsolated() throws Exception {
872870
873871 // Given: three handlers H1, H2 and H3 are registered for sdkUpdate in that order
874872 // And: H2 throws an exception when invoked
875- fixture .client .addEventListener (new SdkEventListener () {
873+ fixture .client .addEventListener (new SplitEventListener () {
876874 @ Override
877875 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
878876 handler1Count .incrementAndGet ();
@@ -881,7 +879,7 @@ public void onUpdate(SplitClient client, SdkUpdateMetadata metadata) {
881879 }
882880 });
883881
884- fixture .client .addEventListener (new SdkEventListener () {
882+ fixture .client .addEventListener (new SplitEventListener () {
885883 @ Override
886884 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
887885 handler2Count .incrementAndGet ();
@@ -891,7 +889,7 @@ public void onUpdate(SplitClient client, SdkUpdateMetadata metadata) {
891889 }
892890 });
893891
894- fixture .client .addEventListener (new SdkEventListener () {
892+ fixture .client .addEventListener (new SplitEventListener () {
895893 @ Override
896894 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
897895 handler3Count .incrementAndGet ();
@@ -948,7 +946,7 @@ public void metadataCorrectlyPropagatedToHandlers() throws Exception {
948946 CountDownLatch updateLatch = new CountDownLatch (1 );
949947
950948 // Given: a handler H is registered for sdkUpdate which inspects the received metadata
951- fixture .client .addEventListener (new SdkEventListener () {
949+ fixture .client .addEventListener (new SplitEventListener () {
952950 @ Override
953951 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
954952 updateHandlerCount .incrementAndGet ();
@@ -1038,15 +1036,15 @@ public void sdkScopedEventsFanOutToMultipleClients() throws Exception {
10381036 CountDownLatch updateLatchB = new CountDownLatch (1 );
10391037
10401038 // And: handlers HA and HB are registered for sdkUpdate
1041- fixture .clientA .addEventListener (new SdkEventListener () {
1039+ fixture .clientA .addEventListener (new SplitEventListener () {
10421040 @ Override
10431041 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
10441042 handlerACount .incrementAndGet ();
10451043 updateLatchA .countDown ();
10461044 }
10471045 });
10481046
1049- fixture .clientB .addEventListener (new SdkEventListener () {
1047+ fixture .clientB .addEventListener (new SplitEventListener () {
10501048 @ Override
10511049 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
10521050 handlerBCount .incrementAndGet ();
@@ -1092,15 +1090,15 @@ public void clientScopedEventsDoNotFanOutToOtherClients() throws Exception {
10921090 CountDownLatch updateLatchB = new CountDownLatch (1 );
10931091
10941092 // And: handlers HA and HB are registered for sdkUpdate
1095- fixture .clientA .addEventListener (new SdkEventListener () {
1093+ fixture .clientA .addEventListener (new SplitEventListener () {
10961094 @ Override
10971095 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
10981096 handlerACount .incrementAndGet ();
10991097 updateLatchA .countDown ();
11001098 }
11011099 });
11021100
1103- fixture .clientB .addEventListener (new SdkEventListener () {
1101+ fixture .clientB .addEventListener (new SplitEventListener () {
11041102 @ Override
11051103 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
11061104 handlerBCount .incrementAndGet ();
@@ -1140,7 +1138,7 @@ public void sdkUpdateMetadataContainsTypeForFlagsUpdate() throws Exception {
11401138 AtomicReference <SdkUpdateMetadata > receivedMetadata = new AtomicReference <>();
11411139 CountDownLatch updateLatch = new CountDownLatch (1 );
11421140
1143- fixture .client .addEventListener (new SdkEventListener () {
1141+ fixture .client .addEventListener (new SplitEventListener () {
11441142 @ Override
11451143 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
11461144 receivedMetadata .set (metadata );
@@ -1182,7 +1180,7 @@ public void sdkUpdateMetadataContainsTypeForSegmentsUpdate() throws Exception {
11821180 AtomicReference <SdkUpdateMetadata > receivedMetadata = new AtomicReference <>();
11831181 CountDownLatch updateLatch = new CountDownLatch (1 );
11841182
1185- fixture .client .addEventListener (new SdkEventListener () {
1183+ fixture .client .addEventListener (new SplitEventListener () {
11861184 @ Override
11871185 public void onUpdate (SplitClient client , SdkUpdateMetadata metadata ) {
11881186 receivedMetadata .set (metadata );
@@ -1285,7 +1283,7 @@ public void onPostExecution(SplitClient c) {
12851283 List <SdkUpdateMetadata > receivedMetadataList = new ArrayList <>();
12861284 CountDownLatch updateLatch = new CountDownLatch (1 );
12871285
1288- client .addEventListener (new SdkEventListener () {
1286+ client .addEventListener (new SplitEventListener () {
12891287 @ Override
12901288 public void onUpdate (SplitClient c , SdkUpdateMetadata metadata ) {
12911289 synchronized (receivedMetadataList ) {
@@ -1470,7 +1468,7 @@ public void onPostExecution(SplitClient c) {
14701468 CountDownLatch updateLatch = new CountDownLatch (expectedEventCount * 2 );
14711469
14721470 // Register new API handler (addEventListener)
1473- client .addEventListener (new SdkEventListener () {
1471+ client .addEventListener (new SplitEventListener () {
14741472 @ Override
14751473 public void onUpdate (SplitClient c , SdkUpdateMetadata metadata ) {
14761474 synchronized (receivedMetadataList ) {
@@ -1841,7 +1839,7 @@ private TwoClientFixture createTwoStreamingClientsAndWaitForReady(Key keyA, Key
18411839 private void registerCacheReadyHandler (SplitClient client , AtomicInteger count ,
18421840 AtomicReference <SdkReadyMetadata > metadata ,
18431841 CountDownLatch latch ) {
1844- client .addEventListener (new SdkEventListener () {
1842+ client .addEventListener (new SplitEventListener () {
18451843 @ Override
18461844 public void onReadyFromCache (SplitClient client , SdkReadyMetadata eventMetadata ) {
18471845 count .incrementAndGet ();
@@ -1856,7 +1854,7 @@ public void onReadyFromCache(SplitClient client, SdkReadyMetadata eventMetadata)
18561854 */
18571855 private void registerUpdateHandler (SplitClient client , AtomicInteger count ,
18581856 AtomicReference <SdkUpdateMetadata > metadata ) {
1859- client .addEventListener (new SdkEventListener () {
1857+ client .addEventListener (new SplitEventListener () {
18601858 @ Override
18611859 public void onUpdate (SplitClient client , SdkUpdateMetadata eventMetadata ) {
18621860 count .incrementAndGet ();
@@ -1881,10 +1879,10 @@ public void onPostExecution(SplitClient client) {
18811879 /**
18821880 * Creates a SdkEventListener that counts onReady invocations and captures metadata.
18831881 */
1884- private SdkEventListener createOnReadyListener (AtomicInteger count ,
1885- AtomicReference <SdkReadyMetadata > metadata ,
1886- CountDownLatch latch ) {
1887- return new SdkEventListener () {
1882+ private SplitEventListener createOnReadyListener (AtomicInteger count ,
1883+ AtomicReference <SdkReadyMetadata > metadata ,
1884+ CountDownLatch latch ) {
1885+ return new SplitEventListener () {
18881886 @ Override
18891887 public void onReady (SplitClient client , SdkReadyMetadata eventMetadata ) {
18901888 if (count != null ) count .incrementAndGet ();
@@ -1897,10 +1895,10 @@ public void onReady(SplitClient client, SdkReadyMetadata eventMetadata) {
18971895 /**
18981896 * Creates a SdkEventListener that counts onUpdate invocations and captures metadata.
18991897 */
1900- private SdkEventListener createOnUpdateListener (AtomicInteger count ,
1901- AtomicReference <SdkUpdateMetadata > metadata ,
1902- CountDownLatch latch ) {
1903- return new SdkEventListener () {
1898+ private SplitEventListener createOnUpdateListener (AtomicInteger count ,
1899+ AtomicReference <SdkUpdateMetadata > metadata ,
1900+ CountDownLatch latch ) {
1901+ return new SplitEventListener () {
19041902 @ Override
19051903 public void onUpdate (SplitClient client , SdkUpdateMetadata eventMetadata ) {
19061904 if (count != null ) count .incrementAndGet ();
@@ -1913,9 +1911,9 @@ public void onUpdate(SplitClient client, SdkUpdateMetadata eventMetadata) {
19131911 /**
19141912 * Creates a SdkEventListener with both onReady and onUpdate handlers.
19151913 */
1916- private SdkEventListener createDualListener (AtomicInteger readyCount , CountDownLatch readyLatch ,
1917- AtomicInteger updateCount , CountDownLatch updateLatch ) {
1918- return new SdkEventListener () {
1914+ private SplitEventListener createDualListener (AtomicInteger readyCount , CountDownLatch readyLatch ,
1915+ AtomicInteger updateCount , CountDownLatch updateLatch ) {
1916+ return new SplitEventListener () {
19191917 @ Override
19201918 public void onReady (SplitClient client , SdkReadyMetadata metadata ) {
19211919 if (readyCount != null ) readyCount .incrementAndGet ();
0 commit comments