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

Single.subscribe介绍

[英]Subscribes to a Single but ignore its emission or notification.

If the Single emits an error, it is wrapped into an io.reactivex.exceptions.OnErrorNotImplementedExceptionand routed to the RxJavaPlugins.onError handler. Scheduler: subscribe does not operate by default on a particular Scheduler.
[中]订阅单个，但忽略其发射或通知。
如果单曲发出错误，它将被包装到io中。reactivex。例外。OnErrorNotImplementedException并路由到RxJavaPlugins。一个错误处理程序。调度程序：订阅默认情况下不会在特定调度程序上运行。

代码示例

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

@Override
  protected void subscribeActual(SingleObserver<? super Notification<T>> observer) {
    source.subscribe(new MaterializeSingleObserver<T>(observer));
  }
}

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

@Test(expected = NullPointerException.class)
public void subscribeOnSuccessNull() {
  just1.subscribe(null, new Consumer<Throwable>() {
    @Override
    public void accept(Throwable e) { }
  });
}

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

@Test(expected = NullPointerException.class)
public void subscribeOnErrorNull() {
  just1.subscribe(new Consumer<Integer>() {
    @Override
    public void accept(Integer v) { }
  }, null);
}

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

@Override
  public void run() {
    error.completable.toSingleDefault(0).subscribe();
  }
});

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

@Test
public void testToMultimap() {
  Observable<String> source = Observable.just("a", "b", "cc", "dd");
  Single<Map<Integer, Collection<String>>> mapped = source.toMultimap(lengthFunc);
  Map<Integer, Collection<String>> expected = new HashMap<Integer, Collection<String>>();
  expected.put(1, Arrays.asList("a", "b"));
  expected.put(2, Arrays.asList("cc", "dd"));
  mapped.subscribe(singleObserver);
  verify(singleObserver, never()).onError(any(Throwable.class));
  verify(singleObserver, times(1)).onSuccess(expected);
}

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

@Test
public void testToMultimapWithValueSelector() {
  Flowable<String> source = Flowable.just("a", "b", "cc", "dd");
  Single<Map<Integer, Collection<String>>> mapped = source.toMultimap(lengthFunc, duplicate);
  Map<Integer, Collection<String>> expected = new HashMap<Integer, Collection<String>>();
  expected.put(1, Arrays.asList("aa", "bb"));
  expected.put(2, Arrays.asList("cccc", "dddd"));
  mapped.subscribe(singleObserver);
  verify(singleObserver, never()).onError(any(Throwable.class));
  verify(singleObserver, times(1)).onSuccess(expected);
}

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

@Test
public void testFirstOrDefault() {
  Single<Integer> o = Observable.just(1, 2, 3)
      .first(4);
  o.subscribe(wo);
  InOrder inOrder = inOrder(wo);
  inOrder.verify(wo, times(1)).onSuccess(1);
  inOrder.verifyNoMoreInteractions();
}

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

@Test
public void testContains() {
  Single<Boolean> o = Observable.just("a", "b", "c").contains("b"); // FIXME nulls not allowed, changed to "c"
  SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  o.subscribe(observer);
  verify(observer, times(1)).onSuccess(true);
  verify(observer, never()).onSuccess(false);
  verify(observer, never()).onError(
      any(Throwable.class));
}

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

private void verifyError(Single<Boolean> single) {
  SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  single.subscribe(observer);
  InOrder inOrder = inOrder(observer);
  inOrder.verify(observer, times(1)).onError(isA(TestException.class));
  inOrder.verifyNoMoreInteractions();
}

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

@Test
public void testSingleOrDefault() {
  Single<Integer> o = Observable.just(1).single(2);
  SingleObserver<Integer> observer = TestHelper.mockSingleObserver();
  o.subscribe(observer);
  InOrder inOrder = inOrder(observer);
  inOrder.verify(observer, times(1)).onSuccess(1);
  inOrder.verifyNoMoreInteractions();
}

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

@Test
public void testCountZeroItems() {
  Flowable<String> flowable = Flowable.empty();
  flowable.count().subscribe(wo);
  // we should be called only once
  verify(wo).onSuccess(0L);
  verify(wo, never()).onError(any(Throwable.class));
}

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

@Test
@Ignore("Null values are not allowed")
public void testListWithNullValue() {
  Flowable<String> w = Flowable.fromIterable(Arrays.asList("one", null, "three"));
  Single<List<String>> single = w.toList();
  SingleObserver<List<String>> observer = TestHelper.mockSingleObserver();
  single.subscribe(observer);
  verify(observer, times(1)).onSuccess(Arrays.asList("one", null, "three"));
  verify(observer, Mockito.never()).onError(any(Throwable.class));
}

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

@Test
public void testIsEmptyWithTwoItems() {
  Flowable<Integer> w = Flowable.just(1, 2);
  Single<Boolean> single = w.isEmpty();
  SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  single.subscribe(observer);
  verify(observer, never()).onSuccess(true);
  verify(observer, times(1)).onSuccess(false);
  verify(observer, never()).onError(any(Throwable.class));
}

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

@Test
public void testIsEmptyWithOneItemFlowable() {
  Flowable<Integer> w = Flowable.just(1);
  Single<Boolean> single = w.isEmpty();
  SingleObserver<Boolean> observer = TestHelper.mockSingleObserver();
  single.subscribe(observer);
  verify(observer, never()).onSuccess(true);
  verify(observer, times(1)).onSuccess(false);
  verify(observer, never()).onError(any(Throwable.class));
}

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

@Test
  public void testLastOrDefault() {
    Single<Integer> single = Flowable.just(1, 2, 3)
        .last(4);

    SingleObserver<Integer> observer = TestHelper.mockSingleObserver();
    single.subscribe(observer);

    InOrder inOrder = inOrder(observer);
    inOrder.verify(observer, times(1)).onSuccess(3);
//        inOrder.verify(observer, times(1)).onComplete();
    inOrder.verifyNoMoreInteractions();
  }

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

@Test
  public void testLastOrDefaultWithEmpty() {
    Single<Integer> single = Flowable.<Integer> empty()
        .last(1);

    SingleObserver<Integer> observer = TestHelper.mockSingleObserver();
    single.subscribe(observer);

    InOrder inOrder = inOrder(observer);
    inOrder.verify(observer, times(1)).onSuccess(1);
//        inOrder.verify(observer, times(1)).onComplete();
    inOrder.verifyNoMoreInteractions();
  }

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

@Test
public void singleSubscribe0() {
  Single.error(new TestException())
  .subscribe();
}

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

@Test
  public void testLastOrDefaultWithEmpty() {
    Single<Integer> o = Observable.<Integer> empty()
        .last(1);

    SingleObserver<Integer> observer = TestHelper.mockSingleObserver();
    o.subscribe(observer);

    InOrder inOrder = inOrder(observer);
    inOrder.verify(observer, times(1)).onSuccess(1);
//        inOrder.verify(observer, times(1)).onComplete();
    inOrder.verifyNoMoreInteractions();
  }

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

@Test
public void testSingleOrDefaultWithTooManyElements() {
  Single<Integer> single = Flowable.just(1, 2).single(3);
  SingleObserver<Integer> observer = TestHelper.mockSingleObserver();
  single.subscribe(observer);
  InOrder inOrder = inOrder(observer);
  inOrder.verify(observer, times(1)).onError(
      isA(IllegalArgumentException.class));
  inOrder.verifyNoMoreInteractions();
}

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

@Test
public void singleSubscribe1() {
  Single.error(new TestException())
  .subscribe(Functions.emptyConsumer());
}