MikolajKakol

    @Provides
    @Singleton
    OkHttpClient okHttpClient() {
        OkHttpClient client = new OkHttpClient();
        if (BuildConfig.OMIT_HTTPS_SECURITY) {
            ignoreHttpsSecurity(client);
        }
        //noinspection ConstantConditions
        if (BuildConfig.HTTP_PROXY_INET != null) {
            client.setProxy(new Proxy(Proxy.Type.HTTP, InetSocketAddress.createUnresolved(BuildConfig.HTTP_PROXY_INET, BuildConfig.HTTP_PROXY_PORT)));

MikolajKakol

package net.test;

import org.junit.Test;

import java.util.concurrent.atomic.AtomicInteger;

import rx.Observable;
import rx.Subscriber;
import rx.functions.Func1;

MikolajKakol

import java.util.Arrays;
import java.util.List;

import junit.framework.TestCase;
import rx.Observable;
import rx.Observer;
import rx.subjects.PublishSubject;
import rx.util.functions.Func1;
import rx.util.functions.Func2;

MikolajKakol

import java.util.Arrays;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

import junit.framework.TestCase;

import org.junit.Test;
import org.junit.runner.RunWith;