View BehaviorSubjectSignals.java
import org.junit.Test; | |
import io.reactivex.disposables.*; | |
import io.reactivex.subjects.BehaviorSubject; | |
public class BehaviorSubjectSignals { | |
@Test | |
public void test() throws Exception { | |
View p22_resistances.txt
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 }, |
View xp.csv
We can make this file beautiful and searchable if this error is corrected: No commas found in this CSV file in line 0.
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 |
View Fallout76_LVLI_Eval.txt
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 |
View ReactiveJMH_benchmark_2.txt
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 |
View HelidonBaseline.txt
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 |
View ObsMergeWithCompTest.java
package hu.akarnokd.rxjava2; | |
import java.util.concurrent.TimeUnit; | |
import org.junit.Test; | |
import io.reactivex.*; | |
public class ObsMergeWithCompTest { |
View LiveDataToRS.java
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) { |
View PublishOnOverrideTckTest.java
package servicetalk; | |
import org.reactivestreams.Publisher; | |
import org.reactivestreams.tck.*; | |
import org.testng.annotations.*; | |
import io.servicetalk.concurrent.api.*; | |
import io.servicetalk.concurrent.reactivestreams.ReactiveStreamsAdapters; | |
@Test |
View RepeatBench.kt
package hu.akarnokd.kotlin | |
import io.reactivex.rxjava3.core.Completable | |
import io.reactivex.rxjava3.schedulers.Schedulers | |
import kotlinx.coroutines.CoroutineScope | |
import kotlinx.coroutines.Dispatchers | |
import kotlinx.coroutines.launch | |
object RepeatBench { | |
@JvmStatic |
NewerOlder