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

Single.toBlocking介绍

暂无

代码示例

代码示例来源：origin: spring-projects/spring-framework

@Test
public void createAndBindToSingle() throws Exception {
  MethodParameter parameter = this.testMethod
      .annotPresent(ModelAttribute.class).arg(Single.class, Foo.class);
  testBindFoo("fooSingle", parameter, single -> {
    assertTrue(single.getClass().getName(), single instanceof Single);
    Object value = ((Single<?>) single).toBlocking().value();
    assertEquals(Foo.class, value.getClass());
    return (Foo) value;
  });
}

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

public String getAndTouchObservable(int i, EVCache gCache, Scheduler scheduler) throws Exception {
  String key = "key_" + i;
  String value = gCache.<String>getAndTouch(key, 60 * 60, scheduler).toBlocking().value();
  if(log.isDebugEnabled()) log.debug("getAndTouch : key : " + key + " val = " + value);
  return value;
}

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

public String getObservable(int i, EVCache gCache, Scheduler scheduler) throws Exception {
  String key = "key_" + i;
  String value = gCache.<String>get(key, scheduler).toBlocking().value();
  if(log.isDebugEnabled()) log.debug("get : key : " + key + " val = " + value);
  return value;
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void publisherToRxSingle() {
  Publisher<Integer> source = Flowable.fromArray(1);
  Object target = getAdapter(rx.Single.class).fromPublisher(source);
  assertTrue(target instanceof rx.Single);
  assertEquals(Integer.valueOf(1), ((rx.Single<Integer>) target).toBlocking().value());
}

代码示例来源：origin: spring-projects/spring-framework

@SuppressWarnings("unchecked")
@Test
public void modelAttributeMethods() throws Exception {
  TestController controller = new TestController();
  InitBinderBindingContext context = getBindingContext(controller);
  Method method = ResolvableMethod.on(TestController.class).annotPresent(GetMapping.class).resolveMethod();
  HandlerMethod handlerMethod = new HandlerMethod(controller, method);
  this.modelInitializer.initModel(handlerMethod, context, this.exchange).block(Duration.ofMillis(5000));
  Map<String, Object> model = context.getModel().asMap();
  assertEquals(5, model.size());
  Object value = model.get("bean");
  assertEquals("Bean", ((TestBean) value).getName());
  value = model.get("monoBean");
  assertEquals("Mono Bean", ((Mono<TestBean>) value).block(Duration.ofMillis(5000)).getName());
  value = model.get("singleBean");
  assertEquals("Single Bean", ((Single<TestBean>) value).toBlocking().value().getName());
  value = model.get("voidMethodBean");
  assertEquals("Void Method Bean", ((TestBean) value).getName());
  value = model.get("voidMonoMethodBean");
  assertEquals("Void Mono Method Bean", ((TestBean) value).getName());
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void singleTestBean() throws Exception {
  String body = "{\"bar\":\"b1\",\"foo\":\"f1\"}";
  ResolvableType type = forClassWithGenerics(Single.class, TestBean.class);
  MethodParameter param = this.testMethod.arg(type);
  Single<TestBean> single = resolveValue(param, body);
  assertEquals(new TestBean("f1", "b1"), single.toBlocking().value());
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void httpEntityWithSingleBody() throws Exception {
  ServerWebExchange exchange = postExchange("line1");
  ResolvableType type = httpEntityType(Single.class, String.class);
  HttpEntity<Single<String>> httpEntity = resolveValue(exchange, type);
  assertEquals(exchange.getRequest().getHeaders(), httpEntity.getHeaders());
  assertEquals("line1", httpEntity.getBody().toBlocking().value());
}

代码示例来源：origin: com.couchbase.client/java-client

@Override
public PingReport ping(long timeout, TimeUnit timeUnit) {
  return asyncBucket.ping(timeout, timeUnit).toBlocking().value();
}

代码示例来源：origin: com.couchbase.client/java-client

@Override
public PingReport ping(Collection<ServiceType> services, long timeout, TimeUnit timeUnit) {
  return asyncBucket.ping(services, timeout, timeUnit).toBlocking().value();
}

代码示例来源：origin: com.couchbase.client/java-client

@Override
public PingReport ping(String reportId, long timeout, TimeUnit timeUnit) {
  return asyncBucket.ping(reportId, timeout, timeUnit).toBlocking().value();
}

代码示例来源：origin: com.couchbase.client/java-client

@Override
public PingReport ping(String reportId, Collection<ServiceType> services, long timeout, TimeUnit timeUnit) {
  return asyncBucket.ping(reportId, services, timeout, timeUnit).toBlocking().value();
}

代码示例来源：origin: org.hawkular.metrics/hawkular-metrics-core-service

private void submitCompressJob(Map<String, String> parameters) {
  String jobName = String.format("%s_single_%s", CompressData.JOB_NAME, parameters.get(CompressData.TARGET_TIME));
  // Blocking to ensure it is actually scheduled..
  scheduler.scheduleJob(CompressData.JOB_NAME, jobName, parameters,
      new SingleExecutionTrigger.Builder().withDelay(1, TimeUnit.MINUTES).build())
      .toBlocking().value();
}

代码示例来源：origin: hawkular/hawkular-metrics

private void submitCompressJob(Map<String, String> parameters) {
  String jobName = String.format("%s_single_%s", CompressData.JOB_NAME, parameters.get(CompressData.TARGET_TIME));
  // Blocking to ensure it is actually scheduled..
  scheduler.scheduleJob(CompressData.JOB_NAME, jobName, parameters,
      new SingleExecutionTrigger.Builder().withDelay(1, TimeUnit.MINUTES).build())
      .toBlocking().value();
}

代码示例来源：origin: hawkular/hawkular-metrics

public TempTableCreator(MetricsService metricsService, ConfigurationService configurationService) {
  service = metricsService;
  Configuration configuration = configurationService.load(CONFIG_ID).toSingle().toBlocking().value();
  if (configuration.get(FORWARD_TIME) != null) {
    forwardTime = java.time.Duration.parse(configuration.get(FORWARD_TIME));
  } else {
    forwardTime = DEFAULT_FORWARD_TIME;
  }
}

代码示例来源：origin: org.hawkular.metrics/hawkular-metrics-core-service

public TempTableCreator(MetricsService metricsService, ConfigurationService configurationService) {
  service = metricsService;
  Configuration configuration = configurationService.load(CONFIG_ID).toSingle().toBlocking().value();
  if (configuration.get(FORWARD_TIME) != null) {
    forwardTime = java.time.Duration.parse(configuration.get(FORWARD_TIME));
  } else {
    forwardTime = DEFAULT_FORWARD_TIME;
  }
}

代码示例来源：origin: alex-shpak/rx-jersey

@Test
public void shouldReturnContent() {
  SingleResource resource = resource(SingleResource.class);
  String message = resource.echo("hello").toBlocking().value();
  assertEquals("hello", message);
}

代码示例来源：origin: alex-shpak/rx-jersey

@Test
public void shouldParseEntity() {
  SingleResource resource = resource(SingleResource.class);
  Entity entity = resource.json("hello").toBlocking().value();
  assertEquals(entity.message, "hello");
}

代码示例来源：origin: alex-shpak/rx-jersey

@Test
public void shouldReturnNoContentOnNull() {
  SingleResource resource = resource(SingleResource.class);
  String message = resource.empty().toBlocking().value();
  assertEquals("", message);
}

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

@Test
public void sample_55() throws Exception {
  Single<String> example =
      fetch("http://www.example.com")
          .flatMap(this::body);
  String b = example.toBlocking().value();
}

代码示例来源：origin: alex-shpak/rx-jersey

@Test(expected = ResponseProcessingException.class)
public void shouldHandleError() {
  SingleResource resource = resource(SingleResource.class);
  String message = resource.error().toBlocking().value();
  assertEquals("", message);
}