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

Single.toMaybe介绍

[英]Converts this Single into a Maybe.

Scheduler: toMaybe does not operate by default on a particular Scheduler.
[中]把这首单曲变成了一首歌。
调度器：toMaybe默认情况下不会在特定的调度器上运行。

代码示例

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

@Override
  public Maybe<Boolean> apply(Maybe<Object> m) throws Exception {
    return m.isEmpty().toMaybe();
  }
});

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

@Override
  public Maybe<Boolean> apply(Maybe<Object> f) throws Exception {
    return f.isEmpty().toMaybe();
  }
});

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

@Test
public void fusedBackToMaybe() {
  assertTrue(Maybe.just(1)
  .isEmpty()
  .toMaybe() instanceof MaybeIsEmpty);
}

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

@Test
public void singleToMaybe() {
  Single.just(1)
  .toMaybe()
  .test()
  .assertResult(1);
}

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

@Test
public void normalToMaybe() {
  Maybe.just(1)
  .isEmpty()
  .toMaybe()
  .test()
  .assertResult(false);
}

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

@Test
public void emptyToMaybe() {
  Maybe.empty()
  .isEmpty()
  .toMaybe()
  .test()
  .assertResult(true);
}

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

@Test
public void isDisposedToMaybe() {
  PublishProcessor<Integer> pp = PublishProcessor.create();
  TestHelper.checkDisposed(pp.singleElement().isEmpty().toMaybe());
}

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

@Test
public void singleToMaybeError() {
  Single.error(new TestException())
  .toMaybe()
  .test()
  .assertFailure(TestException.class);
}

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

@Test
public void singleMaybeSingle() {
  Single.just(1).toMaybe().toSingle().test().assertResult(1);
}

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

@Test
public void errorToMaybe() {
  Maybe.error(new TestException())
  .isEmpty()
  .toMaybe()
  .test()
  .assertFailure(TestException.class);
}

代码示例来源：origin: TeamNewPipe/NewPipe

/**
 * Check if we can load it from the cache (forceLoad parameter), if we can't,
 * load from the network (Single loadFromNetwork)
 * and put the results in the cache.
 */
private static <I extends Info> Single<I> checkCache(boolean forceLoad,
                           int serviceId,
                           String url,
                           Single<I> loadFromNetwork) {
  checkServiceId(serviceId);
  loadFromNetwork = loadFromNetwork.doOnSuccess(info -> cache.putInfo(serviceId, url, info));
  Single<I> load;
  if (forceLoad) {
    cache.removeInfo(serviceId, url);
    load = loadFromNetwork;
  } else {
    load = Maybe.concat(ExtractorHelper.loadFromCache(serviceId, url),
        loadFromNetwork.toMaybe())
        .firstElement() //Take the first valid
        .toSingle();
  }
  return load;
}

代码示例来源：origin: gentics/mesh

@Override
  public Maybe<T> toMaybe() {
    return toSingle().toMaybe();
  }
}

代码示例来源：origin: gentics/mesh

@Override
  public Maybe<T> toMaybe() {
    return toSingle().toMaybe();
  }
}

代码示例来源：origin: gravitee-io/graviteeio-access-management

@Override
public Maybe<User> get(String userId, String baseUrl) {
  LOGGER.debug("Find user by id : {}", userId);
  return userRepository.findById(userId)
      .map(user1 -> convert(user1, baseUrl, false))
      .flatMap(scimUser -> setGroups(scimUser).toMaybe())
      .onErrorResumeNext(ex -> {
        LOGGER.error("An error occurs while trying to find a user using its ID", userId, ex);
        return Maybe.error(new TechnicalManagementException(
            String.format("An error occurs while trying to find a user using its ID: %s", userId), ex));
      });
}

代码示例来源：origin: radixdlt/radixdlt-java

public Observable<UnencryptedData> getReadableData(RadixAddress address) {
  return getData(address)
    .flatMapMaybe(data -> identity.decrypt(data).toMaybe().onErrorComplete());
}

代码示例来源：origin: tsegismont/vertx-musicstore

private Maybe<Buffer> download(Long albumId) {
 return dbClient.rxGetConnection().flatMap(sqlConnection -> {
  return findAlbum(sqlConnection, albumId).doAfterTerminate(sqlConnection::close);
 }).flatMapMaybe(album -> {
  String mbAlbumId = album.getString("mbAlbumId");
  return mbAlbumId == null ? Maybe.empty() : Maybe.just(mbAlbumId);
 }).flatMap(mbAlbumId -> {
  return sendGetRequest(mbAlbumId).toMaybe();
 });
}

代码示例来源：origin: io.gravitee.am.identityprovider/gravitee-am-identityprovider-oauth2-generic

private Maybe<User> profile(String accessToken) {
  return client.getAbs(configuration.getUserProfileUri())
      .putHeader(HttpHeaders.AUTHORIZATION, "Bearer " + accessToken)
      .rxSend()
      .toMaybe()
      .map(httpClientResponse -> {
        if (httpClientResponse.statusCode() != 200) {
          throw new BadCredentialsException(httpClientResponse.statusMessage());
        }
        return createUser(httpClientResponse.bodyAsJsonObject());
      });
}

代码示例来源：origin: gravitee-io/graviteeio-access-management

private Maybe<User> profile(String accessToken) {
  return client.getAbs(configuration.getUserProfileUri())
      .putHeader(HttpHeaders.AUTHORIZATION, "token " + accessToken)
      .rxSend()
      .toMaybe()
      .map(httpClientResponse -> {
        if (httpClientResponse.statusCode() != 200) {
          throw new BadCredentialsException(httpClientResponse.statusMessage());
        }
        return createUser(httpClientResponse.bodyAsJsonObject());
      });
}

代码示例来源：origin: gravitee-io/graviteeio-access-management

private Maybe<User> profile(String accessToken) {
  return client.getAbs(configuration.getUserProfileUri())
      .putHeader(HttpHeaders.AUTHORIZATION, "Bearer " + accessToken)
      .rxSend()
      .toMaybe()
      .map(httpClientResponse -> {
        if (httpClientResponse.statusCode() != 200) {
          throw new BadCredentialsException(httpClientResponse.statusMessage());
        }
        return createUser(httpClientResponse.bodyAsJsonObject());
      });
}

代码示例来源：origin: io.gravitee.am.identityprovider/gravitee-am-identityprovider-github

private Maybe<User> profile(String accessToken) {
  return client.getAbs(configuration.getUserProfileUri())
      .putHeader(HttpHeaders.AUTHORIZATION, "token " + accessToken)
      .rxSend()
      .toMaybe()
      .map(httpClientResponse -> {
        if (httpClientResponse.statusCode() != 200) {
          throw new BadCredentialsException(httpClientResponse.statusMessage());
        }
        return createUser(httpClientResponse.bodyAsJsonObject());
      });
}