ragdroid

infix fun <T>Boolean.then(action : () -> T): T? {
    return if (this)
        action.invoke()
    else null
}

infix fun <T>T?.elze(action: () -> T): T {
    return if (this == null)
        action.invoke()

ragdroid

interface DataStore<T> {

    fun modelListObservable(): Maybe<List<T>>

    fun modelObservable(id: String): Maybe<T>

    fun putModels(vararg models: T)

    fun clear()

ragdroid

    @Inject PokeService pokemonService;   

    @Test
    public void testGetPokemonAbilityStringObservable() {
        PokeDataSource dataSource = new PokeDataSource(pokemonService);
        TestObserver observer = new TestObserver();
        dataSource.getPokemonAbilityStringObservable("12")
                .subscribe(observer);
        observer.assertNoErrors();

ragdroid

    
public Observable<String> getPokemonAbilityStringObservable(String id) {
        return pokemonService.getPokemon(id)
                .map(new Function<Pokemon, String>() {
                    @Override
                    public String apply(@NonNull Pokemon pokemon) throws Exception {
                        return constructAbility(pokemon);
                    }
                });
    }

ragdroid

  
    @Mock MainView mainViewMock;
    @Mock PokeDataSource pokeDataSource;
    @Mock HttpException httpException;

    @Test
    public void testDemoResponseError404() {
        reset(mainViewMock);

        MainPresenterImpl presenter = new MainPresenterImpl(schedulersProvider, pokeDataSource);

ragdroid

    
    @Mock MainView mainViewMock;
    @Mock PokeDataSource pokeDataSource;
    
    @Test
    public void testOnViewAdded() {
        reset(mainViewMock);
        MainPresenterImpl presenter = new MainPresenterImpl(
                                            schedulersProvider, pokeDataSource);

ragdroid

    @Test
    public void testDemoResponseErrorSocket() {
        reset(mainSceneMock);

        MainPresenterImpl presenter = new MainPresenterImpl(schedulersProvider, pokemonService);

        MockResponse response = new MockResponse();
        response.setBody("\"message\":\"Hello\"").throttleBody(1, 2, TimeUnit.SECONDS);

ragdroid

    @Test
    public void testDemoResponseError503() {
        reset(mainSceneMock);
        MainPresenterImpl presenter = new MainPresenterImpl(schedulersProvider, pokemonService);

        MockResponse response = new MockResponse();
        response.setResponseCode(HttpURLConnection.HTTP_UNAVAILABLE);

        getErrorMockWebServer().enqueue(response);

ragdroid

    @Test
    public void testOnSceneAdded() {
        reset(mainSceneMock);
        MainPresenterImpl presenter = new MainPresenterImpl(schedulersProvider, pokemonService);

        presenter.onSceneAdded(mainSceneMock, null);

        testScheduler.triggerActions();

ragdroid

public class LocalResponseDispatcher extends QueueDispatcher {

    @Override
    public MockResponse dispatch(RecordedRequest request) throws InterruptedException {
        MockResponse mockResponse = new MockResponse();
        String scenario = getScenario(request);
        if (scenario != null) {
            try {
                mockResponse.setBody(readFile(scenario));