mzakyalvan

package com.tiket.poc.redis.track;

import java.time.Duration;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import reactor.core.publisher.Mono;

/**
 * @author zakyalvan
 */

mzakyalvan

package com.tiket.poc.redis.track;

import java.time.Duration;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import reactor.core.publisher.Mono;

/**
 * @author zakyalvan
 */

mzakyalvan

package com.tiket.poc.swagger;

import java.util.List;
import org.hamcrest.MatcherAssert;
import org.hamcrest.Matchers;
import org.junit.Test;
import org.mockito.ArgumentCaptor;
import org.mockito.Mockito;

public class MockitoVerifyParametersTests {

mzakyalvan

package reactor.caching;

import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.Caffeine;
import com.github.benmanes.caffeine.cache.Expiry;
import lombok.Builder;
import lombok.Getter;
import org.junit.Test;
import org.mockito.Mockito;
import reactor.cache.CacheMono;

mzakyalvan

package reactor.caching;

import org.junit.Test;
import reactor.cache.CacheMono;
import reactor.core.publisher.Mono;
import reactor.core.publisher.Signal;
import reactor.test.StepVerifier;

import java.util.concurrent.atomic.AtomicReference;
import java.util.function.Consumer;

mzakyalvan

package com.example.demo;

import io.reactivex.Flowable;
import io.reactivex.Single;
import lombok.Getter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

mzakyalvan

package com.tiket.poc;

import org.hamcrest.MatcherAssert;
import org.hamcrest.Matchers;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.ExpectedException;
import org.mockito.Mockito;

public class MockitoTests {

mzakyalvan

package sample;

import java.util.ArrayList;
import java.util.List;
import reactor.core.publisher.Mono;
import reactor.test.StepVerifier;

public class CombiningSample {

  public static void main(String[] args) {

mzakyalvan

package sample;

import io.reactivex.Single;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

public class SimulateTimeout {
  public static void main(String[] args) throws Exception {
    SimulateTimeout sample = new SimulateTimeout();

mzakyalvan

package sample;

import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.boot.SpringApplication;