gistfile1.java

public class TownshipDataRepository implements TownshipRepository{
    private final TownshipDataStoreFactory townshipDataStoreFactory;
    private final TownshipMapper townshipMapper;
    public TownshipDataRepository(TownshipDataStoreFactory townshipDataStoreFactory,TownshipMapper townshipMapper){
        this.townshipDataStoreFactory = townshipDataStoreFactory;
        this.townshipMapper = townshipMapper;
    }
    @Override
    public Observable<List<Township>> townships() {
        return townshipDataStoreFactory.create().townships().map(new Function<List<TownshipEntity>, List<Township>>() {
            @Override
            public List<Township> apply(List<TownshipEntity> townshipEntities) throws Exception {
                return townshipMapper.transformList(townshipEntities);
            }
        });
    }
}