akarnokd

static <T, R> Publisher<R> map(Publisher<T> upstream, Function<T, R> mapper) {
    return downstream -> upstream.subscribe(new Mapper<>(downstream, mapper));
}

class Mapper<T, R> implements Subscriber<T> {

    final Subscriber<? super R> downstream;  
  
    final Function<T, R> mapper;
  

akarnokd

import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

import org.junit.Test;

import io.reactivex.rxjava3.core.Observable;
import io.reactivex.rxjava3.observers.TestObserver;
import io.reactivex.rxjava3.schedulers.TestScheduler;

public class RepeatWhenSO {

akarnokd

import org.junit.Test;

import io.reactivex.disposables.*;
import io.reactivex.subjects.BehaviorSubject;

public class BehaviorSubjectSignals {

    @Test
    public void test() throws Exception {
        

akarnokd

alien
{ level: 1, dr: 50, er: 100, rr: 250, fr: 100, cr: 1000, pr: 100 }, 
{ level: 32, dr: 50, er: 100, rr: 250, fr: 100, cr: 1000, pr: 100 }, 
{ level: 42, dr: 50, er: 100, rr: 250, fr: 100, cr: 1000, pr: 100 }, 
{ level: 52, dr: 50, er: 100, rr: 250, fr: 100, cr: 1000, pr: 100 }, 
{ level: 100, dr: 50, er: 100, rr: 250, fr: 100, cr: 1000, pr: 100 }, 
angler
{ level: 15, dr: 150, er: 125, rr: 350, fr: 125, cr: 125, pr: 125 }, 
{ level: 25, dr: 150, er: 125, rr: 350, fr: 125, cr: 125, pr: 125 }, 
{ level: 37, dr: 150, er: 125, rr: 350, fr: 125, cr: 125, pr: 125 }, 

akarnokd

Enemy	Level	Base	INT	Team	Rested	Relish	Inspire	Double XP	Ingame
Super Mutant	48	102.8	11	2	5	10	15	100	372
Super Mutant	48	102.8	11	2	5	10	10	100	356
Super Mutant	48	102.8	11	2	5	10	5	100	344
Super Mutant	48	102.8	11	2	5	10	0	100	328
Super Mutant	48	102.8	11	4	0	0	15	100	340
Super Mutant	48	102.8	11	4	0	6	15	100	356
Super Mutant	48	102.8	11	3	0	6	15	100	352
Super Mutant	48	102.8	11	3	0	6	10	100	336
Super Mutant	48	102.8	11	3	0	6	5	100	320

akarnokd

LPI_Clothes_LocTheme matches LL_Clothes_LocTheme_Asylum entry (Q:1)
LL_Clothes_LocTheme_Asylum would pick Q:1 of 3 at random
LL_Clothes_Asylum_Rare would pick the first entry that the RNG matched
LLD_Creature_Glowing wants to return 1, goes into LLE_NukeResources_Glowing

LLE_NukeResources_Glowing filters out the entries closest to the target level, then the RNG is matching the filtered entries. Finally, the list picks one of the surviving entries at uniform random.
Essentially the closest to target level will only allow one entry as the entries have distinct level requirements
so pick-one-randomly is a no-op because there would be at most one item to pick.
Let's assume it picked LLS_NukeResources_Glowing
LLS_NukeResources_Glowing has no level requirement and has pick-one-randomly

akarnokd

Benchmark                    (count)   Mode  Cnt          Score          Error  Units
filterAll              1  thrpt    5   28967762,314 ±   453083,236  ops/s
filterAll             10  thrpt    5   21040388,350 ±   532676,051  ops/s
filterAll            100  thrpt    5    1319559,768 ±    44046,703  ops/s
filterAll           1000  thrpt    5     388225,326 ±    14591,618  ops/s
filterAll          10000  thrpt    5      39861,957 ±     1551,280  ops/s
filterAll         100000  thrpt    5       4012,684 ±      216,191  ops/s
filterAll        1000000  thrpt    5        261,647 ±       10,538  ops/s
filterHalf             1  thrpt    5   29159317,586 ±   583423,241  ops/s
filterHalf            10  thrpt    5   15833661,485 ±   739408,073  ops/s

akarnokd

Benchmark                    (count)   Mode  Cnt          Score          Error  Units
filterAll              1  thrpt    5   38420188,130 ±   925965,940  ops/s
filterAll             10  thrpt    5   13698755,182 ±   358946,568  ops/s
filterAll            100  thrpt    5    1661467,594 ±    49667,975  ops/s
filterAll           1000  thrpt    5     167023,857 ±     5220,788  ops/s
filterAll          10000  thrpt    5      16272,792 ±     1059,719  ops/s
filterAll         100000  thrpt    5       1626,623 ±       38,807  ops/s
filterAll        1000000  thrpt    5         72,114 ±        0,868  ops/s
filterHalf             1  thrpt    5   38761421,891 ±   795451,973  ops/s
filterHalf            10  thrpt    5   11969201,224 ±   255486,784  ops/s

akarnokd

package hu.akarnokd.rxjava2;

import java.util.concurrent.TimeUnit;

import org.junit.Test;

import io.reactivex.*;

public class ObsMergeWithCompTest {

akarnokd

        LiveData<List<Integer>> ld = LiveDataReactiveStreams.fromPublisher(
                Flowable.range(1, 5)
                .delay(500, TimeUnit.MILLISECONDS)
                .toList()
                .toFlowable()
        );
        Log.d("TAG", "Sleep");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {