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

/*
 * 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

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

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

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

# 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

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

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 com.example.benchmark

import androidx.benchmark.junit4.BenchmarkRule
import androidx.benchmark.junit4.measureRepeated
import androidx.test.ext.junit.runners.AndroidJUnit4
import androidx.test.filters.LargeTest
import io.reactivex.rxjava3.core.Flowable
import org.junit.Rule
import org.junit.Test
import org.junit.runner.RunWith

SergejIsbrecht

sergej@sergej-P50:~/Development/IdeaProjects/playground$ /home/sergej/.sdkman/candidates/java/13.0.1.hs-adpt/bin/java -version
openjdk version "13.0.1" 2019-10-15
OpenJDK Runtime Environment AdoptOpenJDK (build 13.0.1+9)
OpenJDK 64-Bit Server VM AdoptOpenJDK (build 13.0.1+9, mixed mode, sharing)

sergej@sergej-P50:~/Development/IdeaProjects/playground$ uname -a
Linux sergej-P50 4.18.0-25-generic #26-Ubuntu SMP Mon Jun 24 09:32:08 UTC 2019 x86_64 x86_64 x86_64 GNU/Linux

jol >> java.util.RegularEnumSet, size=1584
jol >> org.eclipse.collections.impl.set.mutable.UnifiedSet, size=976