SergejIsbrecht

Benchmark                                                              Mode  Cnt          Score         Error   Units
Iterate.kotlin_range_default_last                                      avgt   10  129575264.680 ± 4115515.734   ns/op
Iterate.kotlin_range_default_last:·gc.alloc.rate                       avgt   10        775.733 ±      24.638  MB/sec
Iterate.kotlin_range_default_last:·gc.alloc.rate.norm                  avgt   10  110576717.474 ±       0.422    B/op
Iterate.kotlin_range_default_last:·gc.churn.G1_Eden_Space              avgt   10        570.418 ±      21.683  MB/sec
Iterate.kotlin_range_default_last:·gc.churn.G1_Eden_Space.norm         avgt   10   81309181.678 ± 1584945.266    B/op
Iterate.kotlin_range_default_last:·gc.churn.G1_Survivor_Space          avgt   10         12.194 ±       2.404  MB/sec
Iterate.kotlin_range_default_last:·gc.churn.G1_Survivor_Space.norm     avgt   10    1737149.058 ±  326954.321    B/op
Iterate.kotlin_range_default_last:·gc.count                            avgt   10

SergejIsbrecht

package io

import io.reactivex.Flowable
import io.vavr.collection.Iterator
import org.openjdk.jmh.annotations.*
import org.openjdk.jmh.infra.Blackhole
import java.util.concurrent.TimeUnit

@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.NANOSECONDS)

SergejIsbrecht

# JMH version: 1.21
# VM version: JDK 11.0.6, OpenJDK 64-Bit Server VM, 11.0.6+10
# VM invoker: /home/sergej/.sdkman/candidates/java/11.0.6.hs-adpt/bin/java
# VM options: <none>
# Warmup: 7 iterations, 1 s each

Benchmark                                                      Mode  Cnt         Score         Error   Units
RxJava2PlaysScrabbleOpt.play                                   avgt    7        36.204 ±       1.348   ms/op
RxJava2PlaysScrabbleOpt.play:·gc.alloc.rate                    avgt    7       697.418 ±      29.524  MB/sec
RxJava2PlaysScrabbleOpt.play:·gc.alloc.rate.norm               avgt    7  39493711.153 ±       1.493    B/op

SergejIsbrecht

import io.reactivex.Observable;
import io.reactivex.Scheduler;
import io.reactivex.observers.TestObserver;
import io.reactivex.schedulers.Schedulers;
import java.util.Arrays;
import java.util.concurrent.Executors;
import org.junit.jupiter.api.Test;

public class ObserveOnTest {
  @Test

SergejIsbrecht

import io.reactivex.rxjava3.core.Flowable
import io.reactivex.rxjava3.core.Scheduler
import io.reactivex.rxjava3.schedulers.TestScheduler
import org.junit.jupiter.params.ParameterizedTest
import org.junit.jupiter.params.provider.CsvSource
import java.util.concurrent.TimeUnit

class DelayEmits {
    @ParameterizedTest
    @CsvSource("45,225,11", "45,225,5", "225,45,5")

SergejIsbrecht

myLocationService.getLocation()
            .flatMapSingle(new Function<Location, Single<DistanceResponseModel>>() {
                @Override
                public Single<DistanceResponseModel> apply(@NonNull Location location) throws Exception {
                    return distanceRepository.distanceResponseAPI(location.getLatitude() + "," + location.getLongitude(), getDestinations(), "my_google_api_key")
                      .subscribeOn(Schedulers.io());
                }
            })
            .subscribe(new Subscriber<DistanceResponseModel>() {
              

SergejIsbrecht

/*
 * Copyright 2016-2020 JetBrains s.r.o.
 * Use of this source code is governed by the Apache 2.0 License that can be found in the LICENSE.txt file.
 */

package kotlinx.validation

import org.gradle.testkit.runner.BuildResult
import org.gradle.testkit.runner.GradleRunner
import org.gradle.testkit.runner.TaskOutcome

SergejIsbrecht

import io.reactivex.Observable;
import org.junit.jupiter.api.Test;

import java.util.Arrays;

class So65600653 {
  @Test
  void zipTest() {
    Observable<Integer> zip =
        Observable.zip(

SergejIsbrecht

    @Test
    fun fuck1() {
        val dmb = io.reactivex.schedulers.Schedulers.single()
        val watchDog = io.reactivex.schedulers.Schedulers.from(Executors.newSingleThreadExecutor())


        watchDog.scheduleDirect {
            println("watchDog scheduleDirect " + Thread.currentThread().name)
        }

SergejIsbrecht

WITHOUT DEBUG SYMBOLS DWARF

arguments(
        '-H:+PreserveFramePointer',
        '--no-server',
        '--no-fallback',
        '--enable-all-security-services',
        '--report-unsupported-elements-at-runtime'
)