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

Single.blockingGet介绍

[英]Waits in a blocking fashion until the current Single signals a success value (which is returned) or an exception (which is propagated). Scheduler: blockingGet does not operate by default on a particular Scheduler. Error handling: If the source signals an error, the operator wraps a checked Exceptioninto RuntimeException and throws that. Otherwise, RuntimeExceptions and Errors are rethrown as they are.
[中]以阻塞的方式等待，直到当前单信号发出成功值（返回）或异常（传播）的信号。调度程序：默认情况下，blockingGet不会在特定调度程序上运行。错误处理：如果源发出错误信号，操作员将选中的异常包装到RuntimeException中并抛出该异常。否则，运行时异常和错误将按原样重新启动。

代码示例

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

@Override
  public void run() {
    List<Long> values = replay.toList().blockingGet();
    listOfListsOfValues.add(values);
    System.out.println("Finished thread: " + count);
  }
});

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

@Test(expected = NullPointerException.class)
public void fromFutureReturnsNull() {
  FutureTask<Object> f = new FutureTask<Object>(Functions.EMPTY_RUNNABLE, null);
  f.run();
  Single.fromFuture(f).blockingGet();
}

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

@Test(expected = NullPointerException.class)
public void fromFutureTimedReturnsNull() {
  FutureTask<Object> f = new FutureTask<Object>(Functions.EMPTY_RUNNABLE, null);
  f.run();
  Single.fromFuture(f, 1, TimeUnit.SECONDS).blockingGet();
}

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

@SuppressWarnings("unchecked")
@Test(expected = NullPointerException.class)
public void zipIterableOneFunctionReturnsNull() {
  Single.zip(Arrays.asList(just1, just1), new Function<Object[], Object>() {
    @Override
    public Object apply(Object[] v) {
      return null;
    }
  }).blockingGet();
}

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

@SuppressWarnings("unchecked")
@Test(expected = NullPointerException.class)
public void zipIterableTwoIsNull() {
  Single.zip(Arrays.asList(just1, null), new Function<Object[], Object>() {
    @Override
    public Object apply(Object[] v) {
      return 1;
    }
  })
  .blockingGet();
}

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

@SuppressWarnings("unchecked")
@Test(expected = NullPointerException.class)
public void zipArrayOneIsNull() {
  Single.zipArray(new Function<Object[], Object>() {
    @Override
    public Object apply(Object[] v) {
      return 1;
    }
  }, just1, null)
  .blockingGet();
}

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

@Test(expected = NullPointerException.class)
public void liftFunctionReturnsNull() {
  just1.lift(new SingleOperator<Object, Integer>() {
    @Override
    public SingleObserver<? super Integer> apply(SingleObserver<? super Object> observer) {
      return null;
    }
  }).blockingGet();
}

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

@Test(expected = NullPointerException.class)
public void toListSupplierReturnsNullSingle() {
  just1.toList(new Callable<Collection<Integer>>() {
    @Override
    public Collection<Integer> call() {
      return null;
    }
  }).blockingGet();
}

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

@Test(expected = NullPointerException.class)
public void flatMapFunctionReturnsNull() {
  just1.flatMap(new Function<Integer, Single<Object>>() {
    @Override
    public Single<Object> apply(Integer v) {
      return null;
    }
  }).blockingGet();
}

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

@Test(expected = NullPointerException.class)
  public void zipWithFunctionReturnsNull() {
    just1.zipWith(just1, new BiFunction<Integer, Integer, Object>() {
      @Override
      public Object apply(Integer a, Integer b) {
        return null;
      }
    }).blockingGet();
  }
}

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

@SuppressWarnings("unchecked")
@Test(expected = NullPointerException.class)
public void zipIterableTwoIsNull() {
  Single.zip(Arrays.asList(Single.just(1), null), new Function<Object[], Object>() {
    @Override
    public Object apply(Object[] v) {
      return 1;
    }
  })
  .blockingGet();
}

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

@Test(timeout = 2000)
public void testRepeatTake() {
  Observable<Integer> xs = Observable.just(1, 2);
  Object[] ys = xs.repeat().subscribeOn(Schedulers.newThread()).take(4).toList().blockingGet().toArray();
  assertArrayEquals(new Object[] { 1, 2, 1, 2 }, ys);
}

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

@Test
public void testMergeCovariance() {
  Observable<Media> o1 = Observable.<Media> just(new HorrorMovie(), new Movie());
  Observable<Media> o2 = Observable.just(new Media(), new HorrorMovie());
  Observable<Observable<Media>> os = Observable.just(o1, o2);
  List<Media> values = Observable.merge(os).toList().blockingGet();
  assertEquals(4, values.size());
}

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

@Test
public void testMergeCovariance3() {
  Observable<Movie> o1 = Observable.just(new HorrorMovie(), new Movie());
  Observable<Media> o2 = Observable.just(new Media(), new HorrorMovie());
  List<Media> values = Observable.merge(o1, o2).toList().blockingGet();
  assertTrue(values.get(0) instanceof HorrorMovie);
  assertTrue(values.get(1) instanceof Movie);
  assertTrue(values.get(2) != null);
  assertTrue(values.get(3) instanceof HorrorMovie);
}

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

@Test
public void testWithFollowingFirst() {
  Observable<Integer> o = Observable.fromArray(1, 3, 5, 6);
  Single<Boolean> anyEven = o.any(new Predicate<Integer>() {
    @Override
    public boolean test(Integer i) {
      return i % 2 == 0;
    }
  });
  assertTrue(anyEven.blockingGet());
}

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

@Test
public void testMergeCovariance3() {
  Flowable<Movie> f1 = Flowable.just(new HorrorMovie(), new Movie());
  Flowable<Media> f2 = Flowable.just(new Media(), new HorrorMovie());
  List<Media> values = Flowable.merge(f1, f2).toList().blockingGet();
  assertTrue(values.get(0) instanceof HorrorMovie);
  assertTrue(values.get(1) instanceof Movie);
  assertTrue(values.get(2) != null);
  assertTrue(values.get(3) instanceof HorrorMovie);
}

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

@Test
public void fromArityArgs3() {
  Observable<String> items = Observable.just("one", "two", "three");
  assertEquals((Long)3L, items.count().blockingGet());
  assertEquals("two", items.skip(1).take(1).blockingSingle());
  assertEquals("three", items.takeLast(1).blockingSingle());
}

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

@Test
public void testMergeCovariance() {
  Flowable<Media> f1 = Flowable.<Media> just(new HorrorMovie(), new Movie());
  Flowable<Media> f2 = Flowable.just(new Media(), new HorrorMovie());
  Flowable<Flowable<Media>> os = Flowable.just(f1, f2);
  List<Media> values = Flowable.merge(os).toList().blockingGet();
  assertEquals(4, values.size());
}

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

@Test
public void testMergeCovariance2() {
  Flowable<Media> f1 = Flowable.just(new HorrorMovie(), new Movie(), new Media());
  Flowable<Media> f2 = Flowable.just(new Media(), new HorrorMovie());
  Flowable<Flowable<Media>> os = Flowable.just(f1, f2);
  List<Media> values = Flowable.merge(os).toList().blockingGet();
  assertEquals(5, values.size());
}

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

@Test
public void fromArray() {
  String[] items = new String[] { "one", "two", "three" };
  assertEquals((Long)3L, Flowable.fromArray(items).count().blockingGet());
  assertEquals("two", Flowable.fromArray(items).skip(1).take(1).blockingSingle());
  assertEquals("three", Flowable.fromArray(items).takeLast(1).blockingSingle());
}