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

Single.toObservable介绍

[英]Converts this Single into an Observable.

Scheduler: toObservable does not operate by default on a particular Scheduler.
[中]将此单体转换为可观察的。
Scheduler:toObservable默认情况下不会在特定的计划程序上运行。

代码示例

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

@Override
  public ObservableSource<Object> apply(Single<Object> s) throws Exception {
    return s.toObservable();
  }
});

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

@Test
public void testIsEmptyWithTwoItemsObservable() {
  Observable<Integer> w = Observable.just(1, 2);
  Observable<Boolean> observable = w.isEmpty().toObservable();
  Observer<Boolean> observer = TestHelper.mockObserver();
  observable.subscribe(observer);
  verify(observer, never()).onNext(true);
  verify(observer, times(1)).onNext(false);
  verify(observer, never()).onError(any(Throwable.class));
  verify(observer, times(1)).onComplete();
}

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

@Test
public void testIsEmptyWithOneItemObservable() {
  Observable<Integer> w = Observable.just(1);
  Observable<Boolean> observable = w.isEmpty().toObservable();
  Observer<Boolean> observer = TestHelper.mockObserver();
  observable.subscribe(observer);
  verify(observer, never()).onNext(true);
  verify(observer, times(1)).onNext(false);
  verify(observer, never()).onError(any(Throwable.class));
  verify(observer, times(1)).onComplete();
}

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

@Test
public void testContainsObservable() {
  Observable<Boolean> o = Observable.just("a", "b", "c").contains("b").toObservable();
  Observer<Boolean> observer = TestHelper.mockObserver();
  o.subscribe(observer);
  verify(observer, times(1)).onNext(true);
  verify(observer, never()).onNext(false);
  verify(observer, never()).onError(
      any(Throwable.class));
  verify(observer, times(1)).onComplete();
}

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

@Test
public void test1Observable() {
  Observable<Boolean> o = Observable.sequenceEqual(
      Observable.just("one", "two", "three"),
      Observable.just("one", "two", "three")).toObservable();
  verifyResult(o, true);
}

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

@Test
public void testFirstOrDefaultObservable() {
  Observable<Integer> o = Observable.just(1, 2, 3)
      .first(4).toObservable();
  Observer<Integer> observer = TestHelper.mockObserver();
  o.subscribe(observer);
  InOrder inOrder = inOrder(observer);
  inOrder.verify(observer, times(1)).onNext(1);
  inOrder.verify(observer, times(1)).onComplete();
  inOrder.verifyNoMoreInteractions();
}

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

@Test
public void testSingleOrDefaultObservable() {
  Observable<Integer> o = Observable.just(1).single(2).toObservable();
  Observer<Integer> observer = TestHelper.mockObserver();
  o.subscribe(observer);
  InOrder inOrder = inOrder(observer);
  inOrder.verify(observer, times(1)).onNext(1);
  inOrder.verify(observer, times(1)).onComplete();
  inOrder.verifyNoMoreInteractions();
}

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

@Test
public void testWithFollowingFirstObservable() {
  Observable<Integer> o = Observable.just(1, 3, 2, 5, 4);
  assertEquals(Arrays.asList(1, 2, 3, 4, 5), o.toSortedList().toObservable().blockingFirst());
}

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

@SuppressWarnings("unchecked")
@Test
public void toSortedListCapacityObservable() {
  Observable.just(5, 1, 2, 4, 3).toSortedList(4).toObservable()
  .test()
  .assertResult(Arrays.asList(1, 2, 3, 4, 5));
}

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

@Test
public void testFirstOrDefaultWithEmptyObservable() {
  Observable<Integer> o = Observable.<Integer> empty()
      .first(1).toObservable();
  Observer<Integer> observer = TestHelper.mockObserver();
  o.subscribe(observer);
  InOrder inOrder = inOrder(observer);
  inOrder.verify(observer, times(1)).onNext(1);
  inOrder.verify(observer, times(1)).onComplete();
  inOrder.verifyNoMoreInteractions();
}

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

@Test
public void simpleInequalObservable() {
  Observable.sequenceEqual(Observable.just(1), Observable.just(2))
  .toObservable()
  .test()
  .assertResult(false);
}

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

@Test
public void firstOrErrorMultipleElementsObservable() {
  Observable.just(1, 2, 3)
    .firstOrError()
    .toObservable()
    .test()
    .assertNoErrors()
    .assertValue(1);
}

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

@SuppressWarnings("unchecked")
@Test
public void capacityHintObservable() {
  Observable.range(1, 10)
  .toList(4)
  .toObservable()
  .test()
  .assertResult(Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));
}

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

@Test
public void dispose() {
  TestHelper.checkDisposed(Observable.just(1).all(Functions.alwaysTrue()).toObservable());
  TestHelper.checkDisposed(Observable.just(1).all(Functions.alwaysTrue()));
}

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

@Test
public void dispose() {
  TestHelper.checkDisposed(Observable.never().lastElement().toObservable());
  TestHelper.checkDisposed(Observable.never().lastElement());
  TestHelper.checkDisposed(Observable.just(1).lastOrError().toObservable());
  TestHelper.checkDisposed(Observable.just(1).lastOrError());
  TestHelper.checkDisposed(Observable.just(1).last(2).toObservable());
  TestHelper.checkDisposed(Observable.just(1).last(2));
}

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

@Test
public void elementAtIndex1WithDefaultOnEmptySourceObservable() {
  Observable.empty()
    .elementAt(1, 10)
    .toObservable()
    .test()
    .assertResult(10);
}

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

@Test
  public void firstOrErrorErrorObservable() {
    Observable.error(new RuntimeException("error"))
      .firstOrError()
      .toObservable()
      .test()
      .assertNoValues()
      .assertErrorMessage("error")
      .assertError(RuntimeException.class);
  }
}

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

@Test
public void testWithError3Observable() {
  Observable<Boolean> o = Observable.sequenceEqual(
      Observable.concat(Observable.just("one"),
          Observable.<String> error(new TestException())),
      Observable.concat(Observable.just("one"),
          Observable.<String> error(new TestException()))).toObservable();
  verifyError(o);
}

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

@Test
public void testFollowingFirstObservable() {
  Observable<Integer> o = Observable.fromArray(1, 3, 5, 6);
  Observable<Boolean> allOdd = o.all(new Predicate<Integer>() {
    @Override
    public boolean test(Integer i) {
      return i % 2 == 1;
    }
  }).toObservable();
  assertFalse(allOdd.blockingFirst());
}

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

@Test
public void errorObservable() {
  Observable.error(new TestException())
    .elementAt(1, 10)
    .toObservable()
    .test()
    .assertFailure(TestException.class);
}