rx.Observable.delay()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.6k)|赞(0)|评价(0)|浏览(331)

本文整理了Java中rx.Observable.delay()方法的一些代码示例，展示了Observable.delay()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Observable.delay()方法的具体详情如下：
包路径：rx.Observable
类名称：Observable
方法名：delay

Observable.delay介绍

[英]Returns an Observable that emits the items emitted by the source Observable shifted forward in time by a specified delay. Error notifications from the source Observable are not delayed.

Scheduler: This version of delay operates by default on the compuation Scheduler.
[中]返回一个Observable，该Observable发出源Observable发出的项，该源Observable在时间上向前移动了指定的延迟。来自可观测源的错误通知不会延迟。
调度程序：默认情况下，此版本的延迟在计算调度程序上运行。

代码示例

代码示例来源：origin: Netflix/zuul

  1. public Observable<String> makeSlowRequest() {
  2.     return Observable.just("test").delay(500, TimeUnit.MILLISECONDS);
  3.   }
  4. }

代码示例来源：origin: Netflix/zuul

  1. public Observable<String> makeSlowRequest() {
  2.     return Observable.just("test").delay(500, TimeUnit.MILLISECONDS);
  3.   }
  4. }

代码示例来源：origin: konmik/nucleus

  1. @Override
  2. protected void onCreate(Bundle savedState) {
  3.   super.onCreate(savedState);
  4.   restartableLatestCache(GET_ITEM_REQUEST,
  5.     () -> api.getItem(name.split("\\s+")[0], name.split("\\s+")[1], id)
  6.       .map(it -> it.item)
  7.       .delay(pref.getInt("delay", 0), TimeUnit.SECONDS)
  8.       .observeOn(mainThread()),
  9.     ItemFragment::onItem,
  10.     ItemFragment::onNetworkError);
  11. }

代码示例来源：origin: konmik/nucleus

  1. @Override
  2. public void onCreate(Bundle savedState) {
  3.   super.onCreate(savedState);
  4.   restartableReplay(REQUEST_ITEMS,
  5.     () -> pageRequests.startWith(0)
  6.       .concatMap(page ->
  7.         api.getItems(name.split("\\s+")[0], name.split("\\s+")[1], page)
  8.           .map(data -> new PageBundle<>(page, data))
  9.           .delay(pref.getInt("delay", 0), TimeUnit.SECONDS)
  10.           .observeOn(mainThread())),
  11.     (activity, page) -> activity.onItems(page, name),
  12.     MainFragment::onNetworkError);
  13. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. public void loadData() {
  3.  RetrofitHelper.getBangumiAPI()
  4.    .getBangumiIndex()
  5.    .compose(this.bindToLifecycle())
  6.    .doOnSubscribe(this::showProgressBar)
  7.    .subscribeOn(Schedulers.io())
  8.    .delay(2000, TimeUnit.MILLISECONDS)
  9.    .observeOn(AndroidSchedulers.mainThread())
  10.    .subscribe(bangumiIndexInfo -> {
  11.     categorys.addAll(bangumiIndexInfo.getResult().getCategory());
  12.     finishTask();
  13.    }, throwable -> hideProgressBar());
  14. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. public void loadData() {
  3.   RetrofitHelper.getBiliAPI()
  4.       .getActivityCenterList(pageNum, pageSize)
  5.       .compose(bindToLifecycle())
  6.       .delay(1000, TimeUnit.MILLISECONDS)
  7.       .map(ActivityCenterInfo::getList)
  8.       .subscribeOn(Schedulers.io())
  9.       .observeOn(AndroidSchedulers.mainThread())
  10.       .doOnNext(listBeans -> {
  11.         if (listBeans.size() < pageSize) {
  12.           loadMoreView.setVisibility(View.GONE);
  13.           mHeaderViewRecyclerAdapter.removeFootView();
  14.         }
  15.       })
  16.       .subscribe(listBeans -> {
  17.         activityCenters.addAll(listBeans);
  18.         finishTask();
  19.       }, throwable -> {
  20.         if (mSwipeRefreshLayout.isRefreshing()) {
  21.           mSwipeRefreshLayout.setRefreshing(false);
  22.         }
  23.         loadMoreView.setVisibility(View.GONE);
  24.         ToastUtil.ShortToast("加载失败啦,请重新加载~");
  25.       });
  26. }

代码示例来源：origin: PipelineAI/pipeline

  1. @Override
  2. protected Observable<String> construct() {
  3.   executed = true;
  4.   return Observable.just(value).delay(duration, TimeUnit.MILLISECONDS).subscribeOn(Schedulers.computation())
  5.       .doOnNext(new Action1<String>() {
  6.         @Override
  7.         public void call(String t1) {
  8.           System.out.println("successfully executed");
  9.         }
  10.       });
  11. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. public void loadData() {
  3.   RetrofitHelper.getBangumiAPI()
  4.       .getBangumiSchedules()
  5.       .compose(bindToLifecycle())
  6.       .doOnSubscribe(this::showProgressBar)
  7.       .delay(2000, TimeUnit.MILLISECONDS)
  8.       .subscribeOn(Schedulers.io())
  9.       .observeOn(AndroidSchedulers.mainThread())
  10.       .subscribe(bangumiSchedule -> {
  11.         bangumiSchedules.addAll(bangumiSchedule.getResult());
  12.         finishTask();
  13.       }, throwable -> {
  14.         hideProgressBar();
  15.         ToastUtil.ShortToast("加载失败啦,请重新加载~");
  16.       });
  17. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. public void loadData() {
  3.   RetrofitHelper.getVipAPI()
  4.       .getVipGame()
  5.       .compose(bindToLifecycle())
  6.       .doOnSubscribe(this::showProgressBar)
  7.       .delay(2000, TimeUnit.MILLISECONDS)
  8.       .flatMap(new Func1<VipGameInfo, Observable<String>>() {
  9.         @Override
  10.         public Observable<String> call(VipGameInfo vipGameInfo) {
  11.           mVipGameInfoData = vipGameInfo.getData();
  12.           return Observable.just(readAssetsJson());
  13.         }
  14.       })
  15.       .compose(this.bindToLifecycle())
  16.       .subscribeOn(Schedulers.io())
  17.       .observeOn(AndroidSchedulers.mainThread())
  18.       .subscribe(s -> {
  19.         GameCenterInfo gameCenterInfo = new Gson().fromJson(s, GameCenterInfo.class);
  20.         items.addAll(gameCenterInfo.getItems());
  21.         finishTask();
  22.       }, throwable -> hideProgressBar());
  23. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. protected void loadData() {
  3.   RetrofitHelper.getBiliAppAPI()
  4.       .searchBangumi(content, pageNum, pageSize)
  5.       .compose(bindToLifecycle())
  6.       .map(SearchBangumiInfo::getData)
  7.       .delay(1000, TimeUnit.MILLISECONDS)
  8.       .subscribeOn(Schedulers.io())
  9.       .observeOn(AndroidSchedulers.mainThread())
  10.       .doOnNext(dataBean -> {
  11.         if (dataBean.getItems().size() < pageSize) {
  12.           loadMoreView.setVisibility(View.GONE);
  13.           mHeaderViewRecyclerAdapter.removeFootView();
  14.         }
  15.       })
  16.       .subscribe(dataBean -> {
  17.         bangumis.addAll(dataBean.getItems());
  18.         finishTask();
  19.       }, throwable -> {
  20.         hideSearchAnim();
  21.         showEmptyView();
  22.         loadMoreView.setVisibility(View.GONE);
  23.       });
  24. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. protected void loadData() {
  3.   RetrofitHelper.getBiliAppAPI()
  4.       .searchMovie(content, pageNum, pageSize)
  5.       .compose(bindToLifecycle())
  6.       .map(SearchMovieInfo::getData)
  7.       .delay(1000, TimeUnit.MILLISECONDS)
  8.       .subscribeOn(Schedulers.io())
  9.       .observeOn(AndroidSchedulers.mainThread())
  10.       .doOnNext(dataBean -> {
  11.         if (dataBean.getItems().size() < pageSize) {
  12.           loadMoreView.setVisibility(View.GONE);
  13.           mHeaderViewRecyclerAdapter.removeFootView();
  14.         }
  15.       })
  16.       .subscribe(dataBean -> {
  17.         movies.addAll(dataBean.getItems());
  18.         finishTask();
  19.       }, throwable -> {
  20.         hideSearchAnim();
  21.         showEmptyView();
  22.         loadMoreView.setVisibility(View.GONE);
  23.       });
  24. }

代码示例来源：origin: HotBitmapGG/bilibili-android-client

  1. @Override
  2. protected void loadData() {
  3.   RetrofitHelper.getBiliAppAPI()
  4.       .searchUpper(content, pageNum, pageSize)
  5.       .compose(bindToLifecycle())
  6.       .map(SearchUpperInfo::getData)
  7.       .delay(1000, TimeUnit.MILLISECONDS)
  8.       .subscribeOn(Schedulers.io())
  9.       .observeOn(AndroidSchedulers.mainThread())
  10.       .doOnNext(dataBean -> {
  11.         if (dataBean.getItems().size() < pageSize) {
  12.           loadMoreView.setVisibility(View.GONE);
  13.           mHeaderViewRecyclerAdapter.removeFootView();
  14.         }
  15.       })
  16.       .subscribe(dataBean -> {
  17.         uppers.addAll(dataBean.getItems());
  18.         finishTask();
  19.       }, throwable -> {
  20.         hideSearchAnim();
  21.         showEmptyView();
  22.         loadMoreView.setVisibility(View.GONE);
  23.       });
  24. }

代码示例来源：origin: apache/usergrid

  1. createStreamFromWorkers( searchEdge, uniqueIdentifier ).buffer( indexTestFig.getBufferSize() )
  2.   .delay( indexTestFig.getValidateWait(), TimeUnit.MILLISECONDS )

代码示例来源：origin: THEONE10211024/RxJavaSamples

  1. .delay(new Func1<Integer, Observable<Integer>>() {
  2.   @Override
  3.   public Observable<Integer> call(final Integer integer) {

代码示例来源：origin: SpikeKing/wcl-rx-cache-demo

  1. private void fetchUpdates() {
  2.   // 延迟3秒, 模拟效果
  3.   mGitHubClient.getRepos("SpikeKing")
  4.       .delay(3, TimeUnit.SECONDS)
  5.       .subscribeOn(Schedulers.io())
  6.       .observeOn(AndroidSchedulers.mainThread())
  7.       .subscribe(mRepoDb::insertRepoList, this::fetchError, this::fetchComplete);
  8. }

代码示例来源：origin: a-voyager/WeekToDo

  1. private Subscription putOffTaskOneDayWithDelay(int position, TaskDetailEntity entity) {
  2.   return Observable
  3.       .just(1)
  4.       .delay(2, TimeUnit.SECONDS)
  5.       .observeOn(AndroidSchedulers.mainThread())
  6.       .subscribe(a -> {
  7.         putOffTaskOneDay(position, entity);
  8.       });
  9. }

代码示例来源：origin: boredream/DesignResCollection

  1. public static <T> Observable<T> decorate(Observable<T> observable) {
  2.     return observable
  3.         .subscribeOn(Schedulers.newThread())
  4.         .observeOn(AndroidSchedulers.mainThread())
  5.         .delay(1, TimeUnit.SECONDS, AndroidSchedulers.mainThread()); // FIXME 模拟延迟,用于观察加载框等效果
  6.   }
  7. }

代码示例来源：origin: NightscoutFoundation/xDrip

  1. @NonNull
  2. @Override
  3. public Observable<Void> asObservable(BluetoothGatt bluetoothGatt,
  4.                    RxBleGattCallback rxBleGattCallback,
  5.                    Scheduler scheduler) throws Throwable {
  6.   return Observable.fromCallable(() -> refreshDeviceCache(bluetoothGatt))
  7.       .delay(delay_ms, TimeUnit.MILLISECONDS, Schedulers.computation())
  8.       .subscribeOn(scheduler);
  9. }

代码示例来源：origin: jamorham/xDrip-plus

  1. @NonNull
  2. @Override
  3. public Observable<Void> asObservable(BluetoothGatt bluetoothGatt,
  4.                    RxBleGattCallback rxBleGattCallback,
  5.                    Scheduler scheduler) throws Throwable {
  6.   return Observable.fromCallable(() -> refreshDeviceCache(bluetoothGatt))
  7.       .delay(delay_ms, TimeUnit.MILLISECONDS, Schedulers.computation())
  8.       .subscribeOn(scheduler);
  9. }

代码示例来源：origin: nurkiewicz/rxjava-book-examples

  1. @Test
  2. public void sample_355() throws Exception {
  3.   Observable<String> fast = interval(10, MILLISECONDS)
  4.       .map(x -> "F" + x)
  5.       .delay(100, MILLISECONDS)
  6.       .startWith("FX");
  7.   Observable<String> slow = interval(17, MILLISECONDS).map(x -> "S" + x);
  8.   slow
  9.       .withLatestFrom(fast, (s, f) -> s + ":" + f)
  10.       .forEach(System.out::println);
  11. }

内容来源于网络，如有侵权，请联系作者删除！

Observable

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Observable类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com