/**

* Copyright 2016 Netflix, Inc.

*

* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in

* compliance with the License. You may obtain a copy of the License at

*

* http://www.apache.org/licenses/LICENSE-2.0

*

* Unless required by applicable law or agreed to in writing, software distributed under the License is

* distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See

* the License for the specific language governing permissions and limitations under the License.

*/

package io.reactivex;

import static org.mockito.Matchers.any;

import static org.mockito.Mockito.mock;

import java.lang.reflect.*;

import java.util.*;

import org.junit.Assert;

import org.mockito.Mockito;

import org.mockito.invocation.InvocationOnMock;

import org.mockito.stubbing.Answer;

import org.reactivestreams.*;

import io.reactivex.functions.Consumer;

import io.reactivex.plugins.RxJavaPlugins;

/**

* Common methods for helping with tests from 1.x mostly.

*/

public enum TestHelper {

;

/**

* Mocks a subscriber and prepares it to request Long.MAX_VALUE.

* @param <T> the value type

* @return the mocked subscriber

*/

@SuppressWarnings("unchecked")

public static <T> Subscriber<T> mockSubscriber() {

Subscriber<T> w = mock(Subscriber.class);

Mockito.doAnswer(new Answer<Object>() {

@Override

public Object answer(InvocationOnMock a) throws Throwable {

Subscription s = a.getArgumentAt(0, Subscription.class);

s.request(Long.MAX_VALUE);

return null;

}

}).when(w).onSubscribe((Subscription)any());

return w;

}

@SuppressWarnings("unchecked")

public static <T> Observer<T> mockObserver() {

return mock(Observer.class);

}

public static void checkUtilityClass(Class<?> clazz) {

try {

Constructor<?> c = clazz.getDeclaredConstructor();

c.setAccessible(true);

try {

c.newInstance();

Assert.fail("Should have thrown InvocationTargetException(IllegalStateException)");

} catch (InvocationTargetException ex) {

Assert.assertEquals("No instances!", ex.getCause().getMessage());

}

} catch (Exception ex) {

AssertionError ae = new AssertionError(ex.toString());

ae.initCause(ex);

throw ae;

}

}

public static List<Throwable> trackPluginErrors() {

final List<Throwable> list = Collections.synchronizedList(new ArrayList<Throwable>());

RxJavaPlugins.setErrorHandler(new Consumer<Throwable>() {

@Override

public void accept(Throwable t) {

list.add(t);

}

});

return list;

}

public static void assertError(List<Throwable> list, int index, Class<? extends Throwable> clazz, String message) {

Assert.assertTrue(list.get(index).toString(), clazz.isInstance(list.get(index)));

Assert.assertEquals(message, list.get(index).getMessage());

}

}