Skip to content

Instantly share code, notes, and snippets.

David Karnok akarnokd

Block or report user

Report or block akarnokd

Hide content and notifications from this user.

Learn more about blocking users

Contact Support about this user’s behavior.

Learn more about reporting abuse

Report abuse
View GitHub Profile
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
@akarnokd
akarnokd / Reaktive_benchmark.txt
Last active Dec 11, 2019
Reaktive benchmark suite i7 8700, Windows 10 x64, JDk 8u231
View Reaktive_benchmark.txt
Benchmark Mode Cnt Score Error Units
c.b.r.b.j.concatmap.ConcatMapFlow.emitter avgt 10 78,889 ▒ 0,141 ms/op
c.b.r.b.j.concatmap.ConcatMapReaktive.emitter avgt 10 91,053 ▒ 0,372 ms/op
c.b.r.b.j.concatmap.ConcatMapRxJava2.emitter avgt 10 77,697 ▒ 0,270 ms/op
c.b.r.b.j.concatmap.ConcatMapFlow.iterable avgt 10 108,507 ▒ 0,380 ms/op
c.b.r.b.j.concatmap.ConcatMapReaktive.iterable avgt 10 76,537 ▒ 0,185 ms/op
c.b.r.b.j.concatmap.ConcatMapRxJava2.iterable avgt 10 93,363 ▒ 0,319 ms/op
c.b.r.b.j.filtermap.FilterMapFlow.emitter avgt 10 99,514 ▒ 2,216 ms/op
View RetryWhenDelay.java
import java.util.concurrent.TimeUnit;
import org.junit.Test;
import io.reactivex.Observable;
public class RetryWhenDelay {
@Test
public void test() throws Exception {
@akarnokd
akarnokd / log.txt
Created Oct 7, 2019
bnd + gradle 5.6.2+ failure
View log.txt
C:\Users\akarnokd\git\RxJava3_BuildMatrix>gradlew --version
------------------------------------------------------------
Gradle 5.6.2
------------------------------------------------------------
Build time: 2019-09-05 16:13:54 UTC
Revision: 55a5e53d855db8fc7b0e494412fc624051a8e781
Kotlin: 1.3.41
View Scrabble-0810.txt
11-internal+0-shenandoah-jdk11-sobornost-builds.shipilev.net-shenandoah-jdk11-b21-shenandoah-jdk-1125
====
Parallel GC
CyclopsReactOpt sample 100 50.857 ± 0.424 ms/op
Direct sample 804 6.242 ± 0.149 ms/op
GuavaOpt sample 152 33.540 ± 1.766 ms/op
I4JOpt sample 158 32.235 ± 0.135 ms/op
IEOpt sample 267 18.871 ± 0.072 ms/op
View SampleTest.java
import java.util.concurrent.TimeUnit;
import org.junit.Test;
import io.reactivex.Observable;
public class SampleTest {
@Test
public void test() throws Exception {
View ScrabbleDirect729.txt
Benchmark Mode Cnt Score Error Units
ShakespearePlaysScrabbleWithDirect.measureThroughput sample 8822 5,666 � 0,021 ms/op
ShakespearePlaysScrabbleWithDirect.measureThroughput:measureThroughput�p0.00 sample 4,948 ms/op
ShakespearePlaysScrabbleWithDirect.measureThroughput:measureThroughput�p0.50 sample 5,546 ms/op
ShakespearePlaysScrabbleWithDirect.measureThroughput:measureThroughput�p0.90 sample 6,291 ms/op
ShakespearePlaysScrabbleWithDirect.measureThroughput:measureThroughput�p0.95 sample 6,578 ms/op
ShakespearePlaysScrabbleWithDirect.measureThroughput:measureThroughput�p0.99 sample 8,344 ms/op
ShakespearePlaysScrabbleWithDirect.measureThroughput:measureThroughput�p0.999 sample 10,576 ms/op
ShakespearePlaysScrabbleWithDirect.measureThroughput:measureThroughput�p0.9999 sample 17
You can’t perform that action at this time.