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) {

akarnokd

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

akarnokd

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

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

akarnokd

import java.util.concurrent.TimeUnit;

import org.junit.Test;

import io.reactivex.Observable;

public class RetryWhenDelay {

    @Test
    public void test() throws Exception {

akarnokd

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

akarnokd

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

akarnokd

import java.util.concurrent.TimeUnit;

import org.junit.Test;

import io.reactivex.Observable;

public class SampleTest {

    @Test
    public void test() throws Exception {

akarnokd

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