ragdroid

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

ragdroid

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

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

        MainPresenterImpl presenter = new MainPresenterImpl(schedulersProvider, pokeDataSource);

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

    @Inject PokeService pokemonService;   

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

ragdroid

interface DataStore<T> {

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

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

    fun putModels(vararg models: T)

    fun clear()

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()