Skip to content

Instantly share code, notes, and snippets.

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) {
View RxValve.java
import java.util.Queue;
import java.util.concurrent.atomic.*;
import rx.*;
import rx.Observable.Operator;
import rx.exceptions.MissingBackpressureException;
import rx.internal.operators.*;
import rx.internal.util.*;
import rx.internal.util.atomic.SpscAtomicArrayQueue;
View ReactiveFlowBridge.java
package hu.akarnokd.reactiveflowbridge;
import java.util.Objects;
import java.util.concurrent.Flow;
import java.util.function.Function;
/**
* Bridge between Reactive-Streams API and the Java 9 Flow API.
*/
public final class ReactiveFlowBridge {
View SortedMerge.java
import java.util.*;
import java.util.concurrent.atomic.AtomicLong;
import rx.*;
import rx.Observable.OnSubscribe;
import rx.Observable;
import rx.exceptions.*;
import rx.internal.operators.*;
import rx.internal.util.RxRingBuffer;
import rx.internal.util.unsafe.MpscLinkedQueue;
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