Java Result类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.google.android.agera.Result类的典型用法代码示例。如果您正苦于以下问题：Java Result类的具体用法？Java Result怎么用？Java Result使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Result类属于com.google.android.agera包，在下文中一共展示了Result类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: setUpRepository

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

开发者ID:captain-miao，项目名称:AndroidAgeraTutorial，代码行数:24，代码来源:SimpleActivityH.java

示例2: setUpRepository

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

开发者ID:captain-miao，项目名称:AndroidAgeraTutorial，代码行数:22，代码来源:SimpleActivityA.java

示例3: setUpRepository

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

}

开发者ID:captain-miao，项目名称:AndroidAgeraTutorial，代码行数:22，代码来源:ComplexRecycleViewActivity.java

示例4: update

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

}

开发者ID:captain-miao，项目名称:AndroidAgeraTutorial，代码行数:20，代码来源:ComplexRecycleViewActivity.java

示例5: responseTypes

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

开发者ID:drakeet，项目名称:retrofit-agera-call-adapter，代码行数:23，代码来源:AgeraCallAdapterFactoryTest.java

示例6: yinResponseToResult

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

开发者ID:drakeet，项目名称:TimeMachine，代码行数:18，代码来源:YinRequests.java

示例7: mapResponse

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 + " 版");
        });
}

开发者ID:drakeet，项目名称:TimeMachine，代码行数:20，代码来源:AndroidSDKRequests.java

示例8: prepare

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

开发者ID:drakeet，项目名称:TimeMachine，代码行数:27，代码来源:TransformService.java