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 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
@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 RxRange.java
import java.util.concurrent.atomic.AtomicLong;
import rx.Observable.OnSubscribe;
import rx.*;
import rx.internal.operators.BackpressureUtils;
public final class RxRange implements OnSubscribe<Integer> {
final int start;
final int count;
public RxRange(int start, int count) {
You can’t perform that action at this time.