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

Single.as介绍

[英]Calls the specified converter function during assembly time and returns its resulting value.

This allows fluent conversion to any other type. Scheduler: as does not operate by default on a particular Scheduler.
[中]在汇编期间调用指定的转换器函数并返回其结果值。
这允许流畅地转换为任何其他类型。调度程序：默认情况下，as不会在特定调度程序上运行。

代码示例

代码示例来源：origin: ReactiveX/RxJava

@Test(expected = NullPointerException.class)
public void asNull() {
  just1.as(null);
}

代码示例来源：origin: pockethub/PocketHub

@Override
public void onItemClick(@NonNull Item item, @NonNull View view) {
  if (item instanceof UserItem) {
    User result = ((UserItem) item).getUser();
    ServiceGenerator.createService(getContext(), UserService.class)
        .getUser(result.login())
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .as(AutoDisposeUtils.bindToLifecycle(this))
        .subscribe(response ->
            startActivity(UserViewActivity.createIntent(response.body())));
  }
}

代码示例来源：origin: pockethub/PocketHub

@Override
public void onItemClick(@NonNull Item item, @NonNull View view) {
  if (item instanceof ContributorItem) {
    User contributor = ((ContributorItem) item).getUser();
    ServiceGenerator.createService(getContext(), UserService.class)
        .getUser(contributor.login())
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .as(AutoDisposeUtils.bindToLifecycle(this))
        .subscribe(response ->
            startActivity(UserViewActivity.createIntent(response.body())));
  }
}

代码示例来源：origin: pockethub/PocketHub

@Override
public void readNotification(@NonNull NotificationThread thread) {
  ServiceGenerator.createService(getActivity(), NotificationService.class)
      .markNotificationRead(thread.id())
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(response -> refresh(), Throwable::printStackTrace);
}

代码示例来源：origin: ReactiveX/RxJava

@SuppressWarnings({ "rawtypes", "unchecked" })
@Test
public void singleGenericsSignatureTest() {
  A<String, Integer> a = new A<String, Integer>() { };
  Single.just(a).as((SingleConverter)ConverterTest.<String>testSingleConverterCreator());
}

代码示例来源：origin: pockethub/PocketHub

private void reloadOrgs() {
  Single.fromCallable(() -> AccountUtils.getAccount(getAccountManager(), this))
      .map(account -> accountDataManager.getOrgs(false))
      .map(orgs -> {
        Collections.sort(orgs, userComparatorProvider.get());
        return orgs;
      })
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(this::onOrgsLoaded,
          e -> {
            Log.e(TAG, "Exception loading organizations", e);
            ToastUtils.show(this, R.string.error_orgs_load);
          });
}

代码示例来源：origin: pockethub/PocketHub

private void forkRepository() {
  ServiceGenerator.createService(this, RepositoryForkService.class)
      .createFork(repository.owner().login(), repository.name())
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(response -> {
        Repository repo = response.body();
        UriLauncherActivity.launchUri(this, Uri.parse(repo.htmlUrl()));
      }, e -> ToastUtils.show(this, R.string.error_forking_repository));
}

代码示例来源：origin: pockethub/PocketHub

private void starGist() {
  ToastUtils.show(getActivity(), R.string.starring_gist);
  ServiceGenerator.createService(getActivity(), GistService.class)
      .starGist(gistId)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(response -> starred = response.code() == 204,
          e -> ToastUtils.show((Activity) getContext(), e.getMessage()));
}

代码示例来源：origin: pockethub/PocketHub

private void unstarGist() {
  ToastUtils.show(getActivity(), R.string.unstarring_gist);
  ServiceGenerator.createService(getActivity(), GistService.class)
      .unstarGist(gistId)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(response -> starred = !(response.code() == 204),
          e -> ToastUtils.show((Activity) getContext(), e.getMessage()));
}

代码示例来源：origin: pockethub/PocketHub

private void checkFollowingUserStatus() {
    followingStatusChecked = false;
    ServiceGenerator.createService(this, UserFollowerService.class)
        .isFollowing(user.login())
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .as(AutoDisposeUtils.bindToLifecycle(this))
        .subscribe(response -> {
          isFollowing = response.code() == 204;
          followingStatusChecked = true;
          invalidateOptionsMenu();
        });
  }
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void as() {
  Single.just(1).as(new SingleConverter<Integer, Flowable<Integer>>() {
    @Override
    public Flowable<Integer> apply(Single<Integer> v) {
      return v.toFlowable();
    }
  })
  .test()
  .assertResult(1);
}

代码示例来源：origin: pockethub/PocketHub

@Override
public void readNotifications(@Nullable Repository repository) {
  ServiceGenerator.createService(getActivity(), NotificationService.class)
      .markAllRepositoryNotificationsRead(repository.owner().login(),
          repository.name(), NotificationReadRequest.builder().build())
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(response -> refresh(), Throwable::printStackTrace);
}

代码示例来源：origin: pockethub/PocketHub

@Override
protected void createComment(String comment) {
  CommentRequest commentRequest = CommentRequest.builder()
      .body(comment)
      .build();
  ServiceGenerator.createService(this, IssueCommentService.class)
      .createIssueComment(repositoryId.owner().login(), repositoryId.name(), issueNumber, commentRequest)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(response -> finish(response.body()));
}

代码示例来源：origin: pockethub/PocketHub

private void followUser() {
  UserFollowerService service = ServiceGenerator.createService(this, UserFollowerService.class);
  Single<Response<Void>> followSingle;
  if (isFollowing) {
    followSingle = service.unfollowUser(user.login());
  } else{
    followSingle = service.followUser(user.login());
  }
  followSingle.subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(aVoid -> isFollowing = !isFollowing,
          e -> ToastUtils.show(this, isFollowing ? R.string.error_unfollowing_person : R.string.error_following_person));
}

代码示例来源：origin: pockethub/PocketHub

private void checkReadme() {
  loadingBar.setVisibility(View.VISIBLE);
  ServiceGenerator.createService(this, RepositoryContentService.class)
      .hasReadme(repository.owner().login(), repository.name())
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(response -> {
        hasReadme = response.code() == 200;
        configurePager();
      }, e -> {
        hasReadme = false;
        configurePager();
      });
}

代码示例来源：origin: pockethub/PocketHub

private void checkStarredRepositoryStatus() {
  starredStatusChecked = false;
  ServiceGenerator.createService(this, StarringService.class)
      .checkIfRepositoryIsStarred(repository.owner().login(), repository.name())
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(response -> {
        isStarred = response.code() == 204;
        starredStatusChecked = true;
        invalidateOptionsMenu();
      });
}

代码示例来源：origin: pockethub/PocketHub

private void compareCommits() {
  ServiceGenerator.createService(getActivity(), RepositoryCommitService.class)
      .compareCommits(repository.owner().login(), repository.name(), base, head)
      .subscribeOn(Schedulers.io())
      .observeOn(AndroidSchedulers.mainThread())
      .as(AutoDisposeUtils.bindToLifecycle(this))
      .subscribe(response -> {
        CommitCompare compareCommit = response.body();
        List<GitHubFile> files = compareCommit.files();
        diffStyler.setFiles(files);
        Collections.sort(files, new CommitFileComparator());
        updateList(compareCommit);
      }, error -> ToastUtils.show(getActivity(), R.string.error_commits_load));
}

代码示例来源：origin: ReactiveX/RxJava

@Test
public void singleConverterThrows() {
  try {
    Single.just(1).as(new SingleConverter<Integer, Integer>() {
      @Override
      public Integer apply(Single<Integer> v) {
        throw new TestException("Forced failure");
      }
    });
    fail("Should have thrown!");
  } catch (TestException ex) {
    assertEquals("Forced failure", ex.getMessage());
  }
}

代码示例来源：origin: pockethub/PocketHub

@Override
  public void onNegative(MaterialDialog dialog) {
    super.onNegative(dialog);
    dialog.dismiss();
    ServiceGenerator.createService(dialog.getContext(), RepositoryService.class)
        .deleteRepository(repository.owner().login(), repository.name())
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .as(AutoDisposeUtils.bindToLifecycle(getLifecycle()))
        .subscribe(response -> {
          onBackPressed();
          ToastUtils.show(RepositoryViewActivity.this, R.string.delete_successful);
        }, e -> ToastUtils.show(RepositoryViewActivity.this, R.string.error_deleting_repository));
  }
})

代码示例来源：origin: ReactiveX/RxJava

@Test
public void compositeTest() {
  CompositeConverter converter = new CompositeConverter();
  Flowable.just(1)
      .as(converter)
      .test()
      .assertValue(1);
  Observable.just(1)
      .as(converter)
      .test()
      .assertValue(1);
  Maybe.just(1)
      .as(converter)
      .test()
      .assertValue(1);
  Single.just(1)
      .as(converter)
      .test()
      .assertValue(1);
  Completable.complete()
      .as(converter)
      .test()
      .assertComplete();
  Flowable.just(1)
  .parallel()
  .as(converter)
  .test()
  .assertValue(1);
}