import com.google.android.agera.Result; //导入依赖的package包/类
private void setUpRepository() {
    mExecutor = Executors.newSingleThreadExecutor();
    mReservoir = Reservoirs.reservoir();
    Supplier<Result<Integer>> supplier = new Supplier<Result<Integer>>() {
        @NonNull
        @Override
        public Result<Integer> get() {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            mReservoir.get();// consume receiver
            return Result.success(++mCount);
        }
    };
    mRepository = Repositories.repositoryWithInitialValue(Result.<Integer>absent())
            .observe(mReservoir)
            .onUpdatesPerLoop()
            .goTo(mExecutor)
            .thenGetFrom(supplier)
            .compile();
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
private void setUpRepository() {
    mObservable = new OnClickObservable() {
        @Override
        public void onClick( ) {
            dispatchUpdate();
        }
    };
    Supplier<Result<Integer>> supplier = new Supplier<Result<Integer>>() {
        @NonNull
        @Override
        public Result<Integer> get() {
            return Result.success(MockRandomData.getRandomColor());
        }
    };

    mRepository = Repositories.repositoryWithInitialValue(Result.<Integer>absent())
            .observe(mObservable)
            .onUpdatesPerLoop()
            .thenGetFrom(supplier)
            .compile();
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
private void setUpRepository() {
    networkExecutor = Executors.newSingleThreadExecutor();

    mMutableRepository = Repositories.mutableRepository(mPagination);

    mLoadDataRepository = Repositories.repositoryWithInitialValue(Result.<ApiResult<GirlInfo>>absent())
            .observe(mMutableRepository)
            .onUpdatesPerLoop()
            .goTo(networkExecutor)
            .attemptGetFrom(new GirlsSupplier(mMutableRepository)).orSkip()
            .thenTransform(new Function<ApiResult<GirlInfo>, Result<ApiResult<GirlInfo>>>() {
                @NonNull
                @Override
                public Result<ApiResult<GirlInfo>> apply(@NonNull ApiResult<GirlInfo> input) {
                    return absentIfNull(input);
                }
            })
            .onDeactivation(RepositoryConfig.SEND_INTERRUPT)
            .compile();

}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Override
public void update() {
    Result<ApiResult<GirlInfo>> result = mLoadDataRepository.get();

    result.ifSucceededSendTo(this)
            .ifFailedSendTo(new Receiver<Throwable>() {
                @Override
                public void accept(@NonNull Throwable value) {
                    Toast.makeText(ComplexRecycleViewActivity.this, "load data fail", Toast.LENGTH_LONG).show();
                    if (mPagination == 1) {
                        mRefreshRecyclerView.refreshComplete();
                    } else {
                        mRefreshRecyclerView.hideFooterView();
                    }
                    mRefreshRecyclerView.loadMoreComplete();
                }
            });

}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Test public void responseTypes() {
    Type oBodyClass = new TypeToken<Supplier<Result<String>>>() {}.getType();
    assertThat(factory.get(oBodyClass, NO_ANNOTATIONS, retrofit).responseType(),
        equalTo(new TypeToken<String>() {}.getType()));

    Type oBodyWildcard = new TypeToken<Supplier<Result<? extends String>>>() {}.getType();
    assertThat(factory.get(oBodyWildcard, NO_ANNOTATIONS, retrofit).responseType(),
        equalTo(new TypeToken<String>() {}.getType()));

    Type oBodyGeneric = new TypeToken<Supplier<Result<List<String>>>>() {}.getType();
    assertThat(factory.get(oBodyGeneric, NO_ANNOTATIONS, retrofit).responseType(),
        equalTo(new TypeToken<List<String>>() {}.getType()));

    Type oResponseClass = new TypeToken<Supplier<Result<Response<String>>>>() {}.getType();
    assertThat(factory.get(oResponseClass, NO_ANNOTATIONS, retrofit).responseType(),
        equalTo(new TypeToken<String>() {}.getType()));

    Type oResponseWildcard
        = new TypeToken<Supplier<Result<Response<? extends String>>>>() {}.getType();
    assertThat(factory.get(oResponseWildcard, NO_ANNOTATIONS, retrofit).responseType(),
        equalTo(new TypeToken<String>() {}.getType()));
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@NonNull private static Function<HttpResponse, Result<String>> yinResponseToResult() {
    return Functions.functionFrom(HttpResponse.class)
        .apply(input -> new String(input.getBody()))
        .apply(body -> {
            String re = "title\">\\s+.+?href=\"([^\"]*)\">(.+?)</a>.+</li>";
            Pattern pattern = Pattern.compile(re, Pattern.DOTALL);
            return pattern.matcher(body);
        })
        .thenApply(matcher -> {
            if (matcher.find()) {
                return Result.success("为你找到最新的一篇文章是: \n" +
                    matcher.group(2) + "\n" + matcher.group(1));
            } else {
                return Result.absent();
            }
        });
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@NonNull private static Function<HttpResponse, Result<String>> mapResponse() {
    return Functions.functionFrom(HttpResponse.class)
        .apply(input -> new String(input.getBody()))
        .apply(body -> {
            int sourceTag = body.indexOf("<sdk:source>");
            if (sourceTag != -1) {
                String apiLevelStart = "<sdk:api-level>";
                String apiLevelEnd = "</sdk:api-level>";
                int targetStart = body.indexOf(apiLevelStart, sourceTag) +
                    apiLevelStart.length();
                int targetEnd = body.indexOf(apiLevelEnd, targetStart);
                return body.substring(targetStart, targetEnd);
            }
            return "24";
        })
        .thenApply(version -> {
            return Result.success("为你找到最新的 Android SDK Source 是第 " + version + " 版");
        });
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@SuppressWarnings("unchecked") private void prepare() {
    translateReaction = Reservoirs.<Translation>reactionReservoir();
    Repository<Result<String>> translationRepo = repositoryWithInitialValue(
        Result.<String>absent())
        .observe(translateReaction)
        .onUpdatesPerLoop()
        .attemptGetFrom(translateReaction).orSkip()
        .goTo(networkExecutor)
        .check(input -> input.getStep() == OnConfirm)
        .orEnd((Function<Translation, Result<String>>) input -> {
            Log.e("check-confirm", input.toString());
            return Result.failure();
        })
        .mergeIn(YOU_DAO, current2UrlMerger())
        .attemptTransform(urlToResponse())
        .orEnd(Result::failure)
        .goTo(calculationExecutor)
        .transform(youdaoResponseToResult())
        .goLazy()
        .thenTransform(input -> input)
        .onDeactivation(SEND_INTERRUPT)
        .compile();
    translationRepo.addUpdatable(() -> translationRepo.get()
        .ifSucceededSendTo(this::handleConfirm)
        .ifFailedSendTo(errorHandler()));
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Test
public void shouldBindRepositoryPresenterOfResult() {
  final RepositoryPresenter<Result<String>> resultRepositoryPresenter =
      dataBindingRepositoryPresenterOf(String.class)
          .layout(LAYOUT_ID)
          .itemId(ITEM_ID)
          .handler(HANDLER_ID, HANDLER)
          .handler(SECOND_HANDLER_ID, SECOND_HANDLER)
          .forResult();

  resultRepositoryPresenter.bind(STRING_RESULT, 0, viewHolder);

  verify(view).setTag(R.id.agera__rvdatabinding__item_id, ITEM_ID);
  verify(viewDataBinding).setVariable(ITEM_ID, STRING);
  verify(viewDataBinding).setVariable(HANDLER_ID, HANDLER);
  verify(viewDataBinding).setVariable(SECOND_HANDLER_ID, SECOND_HANDLER);
  verify(viewDataBinding).executePendingBindings();
  verifyNoMoreInteractions(viewDataBinding);
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Test
public void shouldRecycleRepositoryPresenterOfResultWithItemRecycling() {
  when(view.getTag(R.id.agera__rvdatabinding__item_id)).thenReturn(ITEM_ID);

  final RepositoryPresenter<Result<String>> resultRepositoryPresenter =
      dataBindingRepositoryPresenterOf(String.class)
          .layout(LAYOUT_ID)
          .itemId(ITEM_ID)
          .handler(HANDLER_ID, HANDLER)
          .handler(SECOND_HANDLER_ID, SECOND_HANDLER)
          .onRecycle(CLEAR_ITEM)
          .forResult();

  resultRepositoryPresenter.recycle(viewHolder);

  verify(viewDataBinding).setVariable(ITEM_ID, null);
  verify(viewDataBinding).executePendingBindings();
  verifyNoMoreInteractions(viewDataBinding);
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Test
public void shouldRecycleRepositoryPresenterOfResultWithAllRecycling() {
  when(view.getTag(R.id.agera__rvdatabinding__item_id)).thenReturn(ITEM_ID);
  final RepositoryPresenter<Result<String>> resultRepositoryPresenter =
      dataBindingRepositoryPresenterOf(String.class)
          .layout(LAYOUT_ID)
          .itemId(ITEM_ID)
          .handler(HANDLER_ID, HANDLER)
          .handler(SECOND_HANDLER_ID, SECOND_HANDLER)
          .onRecycle(CLEAR_ALL)
          .forResult();

  resultRepositoryPresenter.recycle(viewHolder);

  verify(viewDataBinding).setVariable(ITEM_ID, null);
  verify(viewDataBinding).setVariable(HANDLER_ID, null);
  verify(viewDataBinding).setVariable(SECOND_HANDLER_ID, null);
  verify(viewDataBinding).executePendingBindings();
  verifyNoMoreInteractions(viewDataBinding);
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Test
public void shouldRecycleRepositoryPresenterOfResultWithHandlerRecycling() {
  when(view.getTag(R.id.agera__rvdatabinding__item_id)).thenReturn(ITEM_ID);
  final RepositoryPresenter<Result<String>> resultRepositoryPresenter =
      dataBindingRepositoryPresenterOf(String.class)
          .layout(LAYOUT_ID)
          .itemId(ITEM_ID)
          .handler(HANDLER_ID, HANDLER)
          .handler(SECOND_HANDLER_ID, SECOND_HANDLER)
          .onRecycle(CLEAR_HANDLERS)
          .forResult();

  resultRepositoryPresenter.recycle(viewHolder);

  verify(viewDataBinding).setVariable(HANDLER_ID, null);
  verify(viewDataBinding).setVariable(SECOND_HANDLER_ID, null);
  verify(viewDataBinding).executePendingBindings();
  verifyNoMoreInteractions(viewDataBinding);
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Test
public void shouldBindRepositoryPresenterOfResultList() {
  final RepositoryPresenter<Result<List<String>>> resultListRepositoryPresenter =
      dataBindingRepositoryPresenterOf(String.class)
          .layout(LAYOUT_ID)
          .itemId(ITEM_ID)
          .handler(HANDLER_ID, HANDLER)
          .forResultList();

  resultListRepositoryPresenter.bind(STRING_LIST_RESULT, 1, viewHolder);

  verify(view).setTag(R.id.agera__rvdatabinding__item_id, ITEM_ID);
  verify(viewDataBinding).setVariable(ITEM_ID, SECOND_STRING);
  verify(viewDataBinding).setVariable(HANDLER_ID, HANDLER);
  verify(viewDataBinding).executePendingBindings();
  verifyNoMoreInteractions(viewDataBinding);
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Test
public void shouldRecycleRepositoryPresenterOfResultListWithItemRecycling() {
  when(view.getTag(R.id.agera__rvdatabinding__item_id)).thenReturn(ITEM_ID);

  final RepositoryPresenter<Result<List<String>>> resultRepositoryPresenter =
      dataBindingRepositoryPresenterOf(String.class)
          .layout(LAYOUT_ID)
          .itemId(ITEM_ID)
          .handler(HANDLER_ID, HANDLER)
          .handler(SECOND_HANDLER_ID, SECOND_HANDLER)
          .onRecycle(CLEAR_ITEM)
          .forResultList();

  resultRepositoryPresenter.recycle(viewHolder);

  verify(viewDataBinding).setVariable(ITEM_ID, null);
  verify(viewDataBinding).executePendingBindings();
  verifyNoMoreInteractions(viewDataBinding);
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Test
public void shouldRecycleRepositoryPresenterOfResultListWithAllRecycling() {
  when(view.getTag(R.id.agera__rvdatabinding__item_id)).thenReturn(ITEM_ID);
  final RepositoryPresenter<Result<List<String>>> resultRepositoryPresenter =
      dataBindingRepositoryPresenterOf(String.class)
          .layout(LAYOUT_ID)
          .itemId(ITEM_ID)
          .handler(HANDLER_ID, HANDLER)
          .handler(SECOND_HANDLER_ID, SECOND_HANDLER)
          .onRecycle(CLEAR_ALL)
          .forResultList();

  resultRepositoryPresenter.recycle(viewHolder);

  verify(viewDataBinding).setVariable(ITEM_ID, null);
  verify(viewDataBinding).setVariable(HANDLER_ID, null);
  verify(viewDataBinding).setVariable(SECOND_HANDLER_ID, null);
  verify(viewDataBinding).executePendingBindings();
  verifyNoMoreInteractions(viewDataBinding);
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Test
public void shouldRecycleRepositoryPresenterOfResultListWithHandlerRecycling() {
  when(view.getTag(R.id.agera__rvdatabinding__item_id)).thenReturn(ITEM_ID);
  final RepositoryPresenter<Result<List<String>>> resultRepositoryPresenter =
      dataBindingRepositoryPresenterOf(String.class)
          .layout(LAYOUT_ID)
          .itemId(ITEM_ID)
          .handler(HANDLER_ID, HANDLER)
          .handler(SECOND_HANDLER_ID, SECOND_HANDLER)
          .onRecycle(CLEAR_HANDLERS)
          .forResultList();

  resultRepositoryPresenter.recycle(viewHolder);

  verify(viewDataBinding).setVariable(HANDLER_ID, null);
  verify(viewDataBinding).setVariable(SECOND_HANDLER_ID, null);
  verify(viewDataBinding).executePendingBindings();
  verifyNoMoreInteractions(viewDataBinding);
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@NonNull
@Override
public Result<List<T>> merge(@NonNull final SQLiteDatabase database,
    @NonNull final SqlRequest input) {
  try {
    final Cursor cursor = database.rawQuery(input.sql, input.arguments);
    try {
      final int count = cursor.getCount();
      if (count == 0) {
        return success(Collections.<T>emptyList());
      }
      final List<T> items = new ArrayList<>(count);
      while (cursor.moveToNext()) {
        items.add(cursorToItem.apply(cursor));
      }
      return success(items);
    } finally {
      cursor.close();
    }
  } catch (final SQLException e) {
    return failure(e);
  }
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    TwitterAuthConfig authConfig = new TwitterAuthConfig(getString(R.string.twitter_consumer_key), getString(R.string.twitter_consumer_secret));
    Fabric.with(this, new Twitter(authConfig));
    final ActivityMainBinding binding = DataBindingUtil.setContentView(this, R.layout.activity_main);

    // OnRefresh observable
    final OnRefreshObservable refreshObservable = new OnRefreshObservable();
    swipeRefreshLayout = binding.refreshLayout;
    swipeRefreshLayout.setColorSchemeColors(
            ContextCompat.getColor(this, R.color.colorPrimary),
            ContextCompat.getColor(this, R.color.colorAccent),
            ContextCompat.getColor(this, R.color.colorPrimaryDark));
    swipeRefreshLayout.setOnRefreshListener(refreshObservable);

    networkExecutor = Executors.newSingleThreadExecutor();

    // Tweets supplier and repository
    final TweetsSupplier tweetsSupplier = new TweetsSupplier();
    tweetsRepository = Repositories
            .repositoryWithInitialValue(Result.<List<Tweet>>absent())
            .observe(refreshObservable)
            .onUpdatesPerLoop()
            .goTo(networkExecutor)
            .thenGetFrom(tweetsSupplier)
            .compile();

    listAdapter = RepositoryAdapter.repositoryAdapter()
            .add(tweetsRepository, new TweetPresenter())
            .build();
    final RecyclerView list = binding.list;
    list.setAdapter(listAdapter);
    list.setLayoutManager(new LinearLayoutManager(this));
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Override
public int getItemCount(@NonNull Result<List<Tweet>> data) {
    if (data.succeeded()) {
        return data.get().size();
    }
    return 0;
}
 

import com.google.android.agera.Result; //导入依赖的package包/类
@Override
public void bind(@NonNull Result<List<Tweet>> data, int index, @NonNull RecyclerView.ViewHolder holder) {
    if (data.isAbsent() || data.failed()) {
        return;
    }
    final Tweet tweet = data.get().get(index);
    final ListItemTweetBinding binding = DataBindingUtil.bind(holder.itemView);
    binding.userName.setText(tweet.username);
    binding.tweet.setText(tweet.text);
}