Mike Nakhimovich digitalbuddha

	/*
	* The MIT License
	*
	* Copyright (c) 2016 Andreas Ahlenstorf
	*
	* Permission is hereby granted, free of charge, to any person obtaining a copy
	* of this software and associated documentation files (the "Software"), to deal
	* in the Software without restriction, including without limitation the rights
	* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
	* copies of the Software, and to permit persons to whom the Software is

	/*
	* The MIT License
	*
	* Copyright (c) 2016 Andreas Ahlenstorf
	*
	* Permission is hereby granted, free of charge, to any person obtaining a copy
	* of this software and associated documentation files (the "Software"), to deal
	* in the Software without restriction, including without limitation the rights
	* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
	* copies of the Software, and to permit persons to whom the Software is

	Store<Article> Store = ParsingStoreBuilder.<BufferedSource, String>builder()
	.fetcher(this::ResponseAsSource) //responseBody.source()
	.persister(SourcePersisterFactory.create(context.getFilesDir())
	.parser(GsonParserFactory.createSourceParser(gson, Article.class))
	.open();

	Store<Article> articleStore = ParsingStoreBuilder.<BufferedSource, Article>builder()
	.fetcher(barCode -> api.getSource(barCode.getKey()))
	.parser(source -> {
	try (InputStreamReader reader = new InputStreamReader(source.inputStream())) {
	return gson.fromJson(reader, Article.class);
	} catch (IOException e) {
	throw new RuntimeException(e);} })
	.open();

	Store<Article> Store = ParsingStoreBuilder.<BufferedSource, Article>builder()
	.fetcher(this::getResponseAsBufferedSource)
	.parser(GsonParserFactory.createSourceParser(gson, Article.class))
	.open();

	Store<Article> ArticleStore = StoreBuilder.<Article>builder()
	.fetcher(barCode -> retrofitApi.getArticleObservable(barcode.getValue()))
	.open();

	Store<Books> bookStore = ParsingStoreBuilder.<BufferedSource, Books>builder()
	.fetcher(barCode -> api.getSource(barCode.getKey()))
	.persister(SourcePersisterFactory.create(context.getFilesDir())
	.parser(GsonParserFactory.createSourceParser(gson, Books.class))
	.open();

	void getAllCountries(@NonNull final SelectCountryCallback callback, String username){
	// Attempt to get countries from local cache, if present
	if(dbData(callback)) return;

	// Call API to get updated list of countries
	callToApi(callback,username);
	}

	void callToApi(callback,username);
	{

	ApolloWatcher<EpisodeHeroName.Data> watcher = apolloClient.newCall(query).watcher();

	RxApollo
	.toObservable(watcher)
	.subscribe(new Observer<EpisodeHeroName.Data>() {
	@Override public void onCompleted() {

	}

	@Override public void onError(Throwable e) {

Table Of Contents